public interface DoubleCacheStream extends DoubleStream
DoubleStream
that has additional methods to allow for Serializable instances. Please see
CacheStream
for additional details about various methods.DoubleStream.Builder
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
close, isParallel
DoubleCacheStream filter(DoublePredicate predicate)
filter
in interface DoubleStream
DoubleCacheStream filter(SerializableDoublePredicate predicate)
filter(DoublePredicate)
except that the DoublePredicate must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
predicate
- a non-interfering, stateless
predicate to apply to each element to determine if it
should be includedDoubleCacheStream map(DoubleUnaryOperator mapper)
map
in interface DoubleStream
DoubleCacheStream map(SerializableDoubleUnaryOperator mapper)
map(DoubleUnaryOperator)
except that the DoubleUnaryOperator must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
mapper
- a non-interfering, stateless
function to apply to each element<U> CacheStream<U> mapToObj(DoubleFunction<? extends U> mapper)
mapToObj
in interface DoubleStream
<U> CacheStream<U> mapToObj(SerializableDoubleFunction<? extends U> mapper)
mapToObj(DoubleFunction)
except that the DoubleFunction must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
U
- the element type of the new streammapper
- a non-interfering, stateless
function to apply to each elementIntCacheStream mapToInt(DoubleToIntFunction mapper)
mapToInt
in interface DoubleStream
IntCacheStream mapToInt(SerializableDoubleToIntFunction mapper)
mapToInt(DoubleToIntFunction)
except that the DoubleToIntFunction must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
mapper
- a non-interfering, stateless
function to apply to each elementLongCacheStream mapToLong(DoubleToLongFunction mapper)
mapToLong
in interface DoubleStream
LongCacheStream mapToLong(SerializableDoubleToLongFunction mapper)
mapToLong(DoubleToLongFunction)
except that the DoubleToLongFunction must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
mapper
- a non-interfering, stateless
function to apply to each elementDoubleCacheStream flatMap(DoubleFunction<? extends DoubleStream> mapper)
flatMap
in interface DoubleStream
DoubleCacheStream flatMap(SerializableDoubleFunction<? extends DoubleStream> mapper)
flatMap(DoubleFunction)
except that the DoubleFunction must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
mapper
- a non-interfering, stateless
function to apply to each element which produces a
DoubleStream
of new valuesDoubleCacheStream distinct()
distinct
in interface DoubleStream
DoubleCacheStream sorted()
sorted
in interface DoubleStream
DoubleCacheStream peek(DoubleConsumer action)
peek
in interface DoubleStream
DoubleCacheStream peek(SerializableDoubleConsumer action)
flatMap(DoubleFunction)
except that the DoubleFunction must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
action
- a non-interfering action to perform on the elements as
they are consumed from the streamDoubleCacheStream limit(long maxSize)
limit
in interface DoubleStream
DoubleCacheStream skip(long n)
skip
in interface DoubleStream
void forEach(SerializableDoubleConsumer action)
DoubleStream.forEach(DoubleConsumer)
except that the DoubleConsumer must also
implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
action
- a non-interfering action to perform on the elements<K,V> void forEach(ObjDoubleConsumer<Cache<K,V>> action)
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.
K
- key type of the cacheV
- value type of the cacheaction
- consumer to be ran for each element in the stream<K,V> void forEach(SerializableObjDoubleConsumer<Cache<K,V>> action)
K
- key type of the cacheV
- value type of the cacheaction
- consumer to be ran for each element in the streamdouble reduce(double identity, SerializableDoubleBinaryOperator op)
DoubleStream.reduce(double, DoubleBinaryOperator)
except that the DoubleBinaryOperator must
also implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
identity
- the identity value for the accumulating functionop
- an associative, non-interfering, stateless
function for combining two valuesOptionalDouble reduce(SerializableDoubleBinaryOperator op)
DoubleStream.reduce(DoubleBinaryOperator)
except that the DoubleBinaryOperator must
also implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
op
- an associative, non-interfering, stateless
function for combining two values<R> R collect(SerializableSupplier<R> supplier, SerializableObjDoubleConsumer<R> accumulator, SerializableBiConsumer<R,R> combiner)
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
R
- type of the resultsupplier
- 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 resultcombiner
- an associative, non-interfering, stateless
function for combining two values, which must be
compatible with the accumulator functionboolean anyMatch(SerializableDoublePredicate predicate)
DoubleStream.anyMatch(DoublePredicate)
except that the DoublePredicate must
also implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
predicate
- a non-interfering, stateless
predicate to apply to elements of this streamtrue
if any elements of the stream match the provided
predicate, otherwise false
boolean allMatch(SerializableDoublePredicate predicate)
DoubleStream.allMatch(DoublePredicate)
except that the DoublePredicate must
also implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
predicate
- a non-interfering, stateless
predicate to apply to elements of this streamtrue
if either all elements of the stream match the
provided predicate or the stream is empty, otherwise false
boolean noneMatch(SerializableDoublePredicate predicate)
DoubleStream.noneMatch(DoublePredicate)
except that the DoublePredicate must
also implement Serializable
The compiler will pick this overload for lambda parameters, making them Serializable
predicate
- a non-interfering, stateless
predicate to apply to elements of this streamtrue
if either no elements of the stream match the
provided predicate or the stream is empty, otherwise false
CacheStream<Double> boxed()
boxed
in interface DoubleStream
DoubleCacheStream sequential()
sequential
in interface BaseStream<Double,DoubleStream>
sequential
in interface DoubleStream
DoubleCacheStream parallel()
parallel
in interface BaseStream<Double,DoubleStream>
parallel
in interface DoubleStream
DoubleCacheStream unordered()
unordered
in interface BaseStream<Double,DoubleStream>
DoubleCacheStream onClose(Runnable closeHandler)
onClose
in interface BaseStream<Double,DoubleStream>
Copyright © 2016 JBoss, a division of Red Hat. All rights reserved.