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.BuilderallMatch, 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, toArrayclose, isParallelIntCacheStream 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 IntStreamDoubleCacheStream 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 falseboolean 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 falseboolean 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 falseCacheStream<Integer> boxed()
DoubleCacheStream asDoubleStream()
asDoubleStream in interface IntStreamLongCacheStream asLongStream()
asLongStream in interface IntStreamIntCacheStream sequential()
sequential in interface BaseStream<Integer,IntStream>sequential in interface IntStreamIntCacheStream 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.