org.infinispan

Interface DoubleCacheStream

All Superinterfaces:

AutoCloseable, BaseStream<Double,DoubleStream>, DoubleStream

public interface DoubleCacheStream
extends DoubleStream

A DoubleStream that has additional methods to allow for Serializable instances. Please see CacheStream for additional details about various methods.

Since:

8.3

Author:

wburns

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.stream.DoubleStream

DoubleStream.Builder

Method Summary

Modifier and Type	Method and Description
boolean	allMatch(SerializableDoublePredicate predicate) Same as DoubleStream.allMatch(DoublePredicate) except that the DoublePredicate must also implement Serializable
boolean	anyMatch(SerializableDoublePredicate predicate) Same as DoubleStream.anyMatch(DoublePredicate) except that the DoublePredicate must also implement Serializable
CacheStream<Double>	boxed()
<R> R	collect(SerializableSupplier<R> supplier, SerializableObjDoubleConsumer<R> accumulator, SerializableBiConsumer<R,R> combiner) Same as DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer) except that the arguments must also implement Serializable
DoubleCacheStream	distinct()
DoubleCacheStream	filter(DoublePredicate predicate)
DoubleCacheStream	filter(SerializableDoublePredicate predicate) Same as filter(DoublePredicate) except that the DoublePredicate must also implement Serializable
DoubleCacheStream	flatMap(DoubleFunction<? extends DoubleStream> mapper)
DoubleCacheStream	flatMap(SerializableDoubleFunction<? extends DoubleStream> mapper) Same as flatMap(DoubleFunction) except that the DoubleFunction must also implement Serializable
<K,V> void	forEach(ObjDoubleConsumer<Cache<K,V>> action) Same as DoubleStream.forEach(DoubleConsumer) except that it takes an ObjDoubleConsumer that provides access to the underlying Cache that is backing this stream.
void	forEach(SerializableDoubleConsumer action) Same as DoubleStream.forEach(DoubleConsumer) except that the DoubleConsumer must also implement Serializable
<K,V> void	forEach(SerializableObjDoubleConsumer<Cache<K,V>> action) Same as forEach(ObjDoubleConsumer) except that the BiConsumer must also implement Serializable
DoubleCacheStream	limit(long maxSize)
DoubleCacheStream	map(DoubleUnaryOperator mapper)
DoubleCacheStream	map(SerializableDoubleUnaryOperator mapper) Same as map(DoubleUnaryOperator) except that the DoubleUnaryOperator must also implement Serializable
IntCacheStream	mapToInt(DoubleToIntFunction mapper)
IntCacheStream	mapToInt(SerializableDoubleToIntFunction mapper) Same as mapToInt(DoubleToIntFunction) except that the DoubleToIntFunction must also implement Serializable
LongCacheStream	mapToLong(DoubleToLongFunction mapper)
LongCacheStream	mapToLong(SerializableDoubleToLongFunction mapper) Same as mapToLong(DoubleToLongFunction) except that the DoubleToLongFunction must also implement Serializable
<U> CacheStream<U>	mapToObj(DoubleFunction<? extends U> mapper)
<U> CacheStream<U>	mapToObj(SerializableDoubleFunction<? extends U> mapper) Same as mapToObj(DoubleFunction) except that the DoubleFunction must also implement Serializable
boolean	noneMatch(SerializableDoublePredicate predicate) Same as DoubleStream.noneMatch(DoublePredicate) except that the DoublePredicate must also implement Serializable
DoubleCacheStream	onClose(Runnable closeHandler)
DoubleCacheStream	parallel()
DoubleCacheStream	peek(DoubleConsumer action)
DoubleCacheStream	peek(SerializableDoubleConsumer action) Same as flatMap(DoubleFunction) except that the DoubleFunction must also implement Serializable
double	reduce(double identity, SerializableDoubleBinaryOperator op) Same as DoubleStream.reduce(double, DoubleBinaryOperator) except that the DoubleBinaryOperator must also implement Serializable
OptionalDouble	reduce(SerializableDoubleBinaryOperator op) Same as DoubleStream.reduce(DoubleBinaryOperator) except that the DoubleBinaryOperator must also implement Serializable
DoubleCacheStream	sequential()
DoubleCacheStream	skip(long n)
DoubleCacheStream	sorted()
DoubleCacheStream	unordered()

Methods inherited from interface java.util.stream.DoubleStream

allMatch, anyMatch, average, builder, collect, concat, count, empty, findAny, findFirst, forEach, forEachOrdered, generate, iterate, iterator, max, min, noneMatch, of, of, reduce, reduce, spliterator, sum, summaryStatistics, toArray

Methods inherited from interface java.util.stream.BaseStream

close, isParallel

Method Detail

filter

DoubleCacheStream filter(DoublePredicate predicate)

Specified by:

filter in interface DoubleStream

Returns:

the new cache double stream

filter

DoubleCacheStream filter(SerializableDoublePredicate predicate)

Same as filter(DoublePredicate) except that the DoublePredicate must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

predicate - a non-interfering, stateless predicate to apply to each element to determine if it should be included

Returns:

the new cache double stream

map

DoubleCacheStream map(DoubleUnaryOperator mapper)

Specified by:

map in interface DoubleStream

Returns:

the new cache double stream

map

DoubleCacheStream map(SerializableDoubleUnaryOperator mapper)

Same as map(DoubleUnaryOperator) except that the DoubleUnaryOperator must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

mapper - a non-interfering, stateless function to apply to each element

Returns:

the new cache double stream

mapToObj

<U> CacheStream<U> mapToObj(DoubleFunction<? extends U> mapper)

Specified by:

mapToObj in interface DoubleStream

Returns:

the new cache stream

mapToObj

<U> CacheStream<U> mapToObj(SerializableDoubleFunction<? extends U> mapper)

Same as mapToObj(DoubleFunction) except that the DoubleFunction must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Type Parameters:

U - the element type of the new stream

Parameters:

mapper - a non-interfering, stateless function to apply to each element

Returns:

the new cache stream

mapToInt

IntCacheStream mapToInt(DoubleToIntFunction mapper)

Specified by:

mapToInt in interface DoubleStream

Returns:

the new cache int stream

mapToInt

IntCacheStream mapToInt(SerializableDoubleToIntFunction mapper)

Same as mapToInt(DoubleToIntFunction) except that the DoubleToIntFunction must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

mapper - a non-interfering, stateless function to apply to each element

Returns:

the new cache int stream

mapToLong

LongCacheStream mapToLong(DoubleToLongFunction mapper)

Specified by:

mapToLong in interface DoubleStream

Returns:

the new cache long stream

mapToLong

LongCacheStream mapToLong(SerializableDoubleToLongFunction mapper)

Same as mapToLong(DoubleToLongFunction) except that the DoubleToLongFunction must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

mapper - a non-interfering, stateless function to apply to each element

Returns:

the new cache long stream

flatMap

DoubleCacheStream flatMap(DoubleFunction<? extends DoubleStream> mapper)

Specified by:

flatMap in interface DoubleStream

Returns:

the new cache double stream

flatMap

DoubleCacheStream flatMap(SerializableDoubleFunction<? extends DoubleStream> mapper)

Same as flatMap(DoubleFunction) except that the DoubleFunction must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

mapper - a non-interfering, stateless function to apply to each element which produces a DoubleStream of new values

Returns:

the new cache double stream

distinct

DoubleCacheStream distinct()

Specified by:

distinct in interface DoubleStream

Returns:

the new cache double stream

sorted

DoubleCacheStream sorted()

Specified by:

sorted in interface DoubleStream

Returns:

the new cache double stream

peek

DoubleCacheStream peek(DoubleConsumer action)

Specified by:

peek in interface DoubleStream

Returns:

the new cache double stream

peek

DoubleCacheStream peek(SerializableDoubleConsumer action)

Same as flatMap(DoubleFunction) except that the DoubleFunction must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

action - a non-interfering action to perform on the elements as they are consumed from the stream

Returns:

the new cache double stream

limit

DoubleCacheStream limit(long maxSize)

Specified by:

limit in interface DoubleStream

Returns:

the new cache double stream

skip

DoubleCacheStream skip(long n)

Specified by:

skip in interface DoubleStream

Returns:

the new cache double stream

forEach

void forEach(SerializableDoubleConsumer action)

Same as DoubleStream.forEach(DoubleConsumer) except that the DoubleConsumer must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

action - a non-interfering action to perform on the elements

forEach

<K,V> void forEach(ObjDoubleConsumer<Cache<K,V>> action)

Same as DoubleStream.forEach(DoubleConsumer) except that it takes an ObjDoubleConsumer that provides access to the underlying Cache that is backing this stream.

Note that the CacheAware interface is not supported for injection using this method as the cache is provided in the consumer directly.

Type Parameters:

K - key type of the cache

V - value type of the cache

Parameters:

action - consumer to be ran for each element in the stream

forEach

<K,V> void forEach(SerializableObjDoubleConsumer<Cache<K,V>> action)

Same as forEach(ObjDoubleConsumer) except that the BiConsumer must also implement Serializable

Type Parameters:

K - key type of the cache

V - value type of the cache

Parameters:

action - consumer to be ran for each element in the stream

reduce

double reduce(double identity,
              SerializableDoubleBinaryOperator op)

Same as DoubleStream.reduce(double, DoubleBinaryOperator) except that the DoubleBinaryOperator must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

identity - the identity value for the accumulating function

op - an associative, non-interfering, stateless function for combining two values

Returns:

the result of the reduction

reduce

OptionalDouble reduce(SerializableDoubleBinaryOperator op)

Same as DoubleStream.reduce(DoubleBinaryOperator) except that the DoubleBinaryOperator must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

op - an associative, non-interfering, stateless function for combining two values

Returns:

the result of the reduction

collect

<R> R collect(SerializableSupplier<R> supplier,
              SerializableObjDoubleConsumer<R> accumulator,
              SerializableBiConsumer<R,R> combiner)

Same as DoubleStream.collect(Supplier, ObjDoubleConsumer, BiConsumer) except that the arguments must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Type Parameters:

R - type of the result

Parameters:

supplier - a function that creates a new result container. For a parallel execution, this function may be called multiple times and must return a fresh value each time.

accumulator - an associative, non-interfering, stateless function for incorporating an additional element into a result

combiner - an associative, non-interfering, stateless function for combining two values, which must be compatible with the accumulator function

Returns:

the result of the reduction

anyMatch

boolean anyMatch(SerializableDoublePredicate predicate)

Same as DoubleStream.anyMatch(DoublePredicate) except that the DoublePredicate must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

predicate - a non-interfering, stateless predicate to apply to elements of this stream

Returns:

true if any elements of the stream match the provided predicate, otherwise false

allMatch

boolean allMatch(SerializableDoublePredicate predicate)

Same as DoubleStream.allMatch(DoublePredicate) except that the DoublePredicate must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

predicate - a non-interfering, stateless predicate to apply to elements of this stream

Returns:

true if either all elements of the stream match the provided predicate or the stream is empty, otherwise false

noneMatch

boolean noneMatch(SerializableDoublePredicate predicate)

Same as DoubleStream.noneMatch(DoublePredicate) except that the DoublePredicate must also implement Serializable

The compiler will pick this overload for lambda parameters, making them Serializable

Parameters:

predicate - a non-interfering, stateless predicate to apply to elements of this stream

Returns:

true if either no elements of the stream match the provided predicate or the stream is empty, otherwise false

boxed

CacheStream<Double> boxed()

Specified by:

boxed in interface DoubleStream

Returns:

the new cache stream containing doubles

sequential

DoubleCacheStream sequential()

Specified by:

sequential in interface BaseStream<Double,DoubleStream>

Specified by:

sequential in interface DoubleStream

Returns:

a sequential cache double stream

parallel

DoubleCacheStream parallel()

Specified by:

parallel in interface BaseStream<Double,DoubleStream>

Specified by:

parallel in interface DoubleStream

Returns:

a parallel cache double stream

unordered

DoubleCacheStream unordered()

Specified by:

unordered in interface BaseStream<Double,DoubleStream>

Returns:

an unordered cache double stream

onClose

DoubleCacheStream onClose(Runnable closeHandler)

Specified by:

onClose in interface BaseStream<Double,DoubleStream>

Returns:

a cache double stream with the handler applied