public interface IntCacheStream extends IntStream
IntStream
that has additional methods to allow for Serializable instances. Please see
CacheStream
for additional details about various methods.IntStream.Builder
allMatch, anyMatch, average, builder, collect, concat, count, empty, findAny, findFirst, forEach, forEachOrdered, generate, iterate, iterator, max, min, noneMatch, of, of, range, rangeClosed, reduce, reduce, spliterator, sum, summaryStatistics, toArray
close, isParallel
IntCacheStream filter(IntPredicate predicate)
IntCacheStream filter(SerializableIntPredicate predicate)
filter(IntPredicate)
except that the IntPredicate 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 includedIntCacheStream map(IntUnaryOperator mapper)
IntCacheStream map(SerializableIntUnaryOperator mapper)
map(IntUnaryOperator)
except that the IntUnaryOperator 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(IntFunction<? extends U> mapper)
<U> CacheStream<U> mapToObj(SerializableIntFunction<? extends U> mapper)
mapToObj(IntFunction)
except that the IntFunction 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 elementDoubleCacheStream mapToDouble(IntToDoubleFunction mapper)
mapToDouble
in interface IntStream
DoubleCacheStream mapToDouble(SerializableIntToDoubleFunction mapper)
mapToDouble(IntToDoubleFunction)
except that the IntToIntFunction 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(IntToLongFunction mapper)
LongCacheStream mapToLong(SerializableIntToLongFunction mapper)
mapToLong(IntToLongFunction)
except that the IntToLongFunction 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 elementIntCacheStream flatMap(IntFunction<? extends IntStream> mapper)
IntCacheStream flatMap(SerializableIntFunction<? extends IntStream> mapper)
flatMap(IntFunction)
except that the IntFunction 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
IntStream
of new valuesIntCacheStream distinct()
IntCacheStream sorted()
IntCacheStream peek(IntConsumer action)
IntCacheStream peek(SerializableIntConsumer action)
flatMap(IntFunction)
except that the IntFunction 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 streamIntCacheStream limit(long maxSize)
IntCacheStream skip(long n)
void forEach(SerializableIntConsumer action)
IntStream.forEach(IntConsumer)
except that the IntConsumer 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(ObjIntConsumer<Cache<K,V>> action)
IntStream.forEach(IntConsumer)
except that it takes an ObjIntConsumer
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(SerializableObjIntConsumer<Cache<K,V>> action)
K
- key type of the cacheV
- value type of the cacheaction
- consumer to be ran for each element in the streamint reduce(int identity, SerializableIntBinaryOperator op)
IntStream.reduce(int, IntBinaryOperator)
except that the IntBinaryOperator
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 valuesOptionalInt reduce(SerializableIntBinaryOperator op)
IntStream.reduce(IntBinaryOperator)
except that the IntBinaryOperator 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, SerializableObjIntConsumer<R> accumulator, SerializableBiConsumer<R,R> combiner)
IntStream.collect(Supplier, ObjIntConsumer, 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(SerializableIntPredicate predicate)
IntStream.anyMatch(IntPredicate)
except that the IntPredicate 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(SerializableIntPredicate predicate)
IntStream.allMatch(IntPredicate)
except that the IntPredicate 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(SerializableIntPredicate predicate)
IntStream.noneMatch(IntPredicate)
except that the IntPredicate 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<Integer> boxed()
DoubleCacheStream asDoubleStream()
asDoubleStream
in interface IntStream
LongCacheStream asLongStream()
asLongStream
in interface IntStream
IntCacheStream sequential()
sequential
in interface BaseStream<Integer,IntStream>
sequential
in interface IntStream
IntCacheStream parallel()
IntCacheStream unordered()
unordered
in interface BaseStream<Integer,IntStream>
IntCacheStream onClose(Runnable closeHandler)
onClose
in interface BaseStream<Integer,IntStream>
Copyright © 2017 JBoss, a division of Red Hat. All rights reserved.