org.infinispan

Interface LongCacheStream

All Superinterfaces:

AutoCloseable, BaseStream<Long,LongStream>, LongStream

public interface LongCacheStream
extends LongStream

A LongStream 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.LongStream

LongStream.Builder

Method Summary

Modifier and Type	Method and Description
default boolean	allMatch(SerializableLongPredicate predicate) Same as LongStream.allMatch(LongPredicate) except that the LongPredicate must also implement Serializable.
default boolean	anyMatch(SerializableLongPredicate predicate) Same as LongStream.anyMatch(LongPredicate) except that the LongPredicate must also implement Serializable.
DoubleCacheStream	asDoubleStream()
CacheStream<Long>	boxed()
default <R> R	collect(SerializableSupplier<R> supplier, SerializableObjLongConsumer<R> accumulator, SerializableBiConsumer<R,R> combiner) Same as LongStream.collect(Supplier, ObjLongConsumer, BiConsumer) except that the arguments must also implement Serializable.
LongCacheStream	distinct()
LongCacheStream	filter(LongPredicate predicate)
default LongCacheStream	filter(SerializableLongPredicate predicate) Same as filter(LongPredicate) except that the LongPredicate must also implement Serializable.
LongCacheStream	flatMap(LongFunction<? extends LongStream> mapper)
default LongCacheStream	flatMap(SerializableLongFunction<? extends LongStream> mapper) Same as flatMap(LongFunction) except that the LongFunction must also implement Serializable.
<K,V> void	forEach(ObjLongConsumer<Cache<K,V>> action) Same as LongStream.forEach(LongConsumer) except that it takes an ObjLongConsumer that provides access to the underlying Cache that is backing this stream.
default void	forEach(SerializableLongConsumer action) Same as LongStream.forEach(LongConsumer) except that the LongConsumer must also implement Serializable.
default <K,V> void	forEach(SerializableObjLongConsumer<Cache<K,V>> action) Same as forEach(ObjLongConsumer) except that the BiConsumer must also implement Serializable
LongCacheStream	limit(long maxSize)
LongCacheStream	map(LongUnaryOperator mapper)
default LongCacheStream	map(SerializableLongUnaryOperator mapper) Same as map(LongUnaryOperator) except that the LongUnaryOperator must also implement Serializable.
DoubleCacheStream	mapToDouble(LongToDoubleFunction mapper)
default DoubleCacheStream	mapToDouble(SerializableLongToDoubleFunction mapper) Same as mapToDouble(LongToDoubleFunction) except that the LongToLongFunction must also implement Serializable.
IntCacheStream	mapToInt(LongToIntFunction mapper)
default IntCacheStream	mapToInt(SerializableLongToIntFunction mapper) Same as mapToInt(LongToIntFunction) except that the LongToIntFunction must also implement Serializable.
<U> CacheStream<U>	mapToObj(LongFunction<? extends U> mapper)
default <U> CacheStream<U>	mapToObj(SerializableLongFunction<? extends U> mapper) Same as mapToObj(LongFunction) except that the LongFunction must also implement Serializable.
default boolean	noneMatch(SerializableLongPredicate predicate) Same as LongStream.noneMatch(LongPredicate) except that the LongPredicate must also implement Serializable.
LongCacheStream	onClose(Runnable closeHandler)
LongCacheStream	parallel()
LongCacheStream	peek(LongConsumer action)
default LongCacheStream	peek(SerializableLongConsumer action) Same as flatMap(LongFunction) except that the LongFunction must also implement Serializable.
default long	reduce(long identity, SerializableLongBinaryOperator op) Same as LongStream.reduce(long, LongBinaryOperator) except that the LongBinaryOperator must also implement Serializable.
default OptionalLong	reduce(SerializableLongBinaryOperator op) Same as LongStream.reduce(LongBinaryOperator) except that the LongBinaryOperator must also implement Serializable.
LongCacheStream	sequential()
LongCacheStream	skip(long n)
LongCacheStream	sorted()
LongCacheStream	unordered()

Methods inherited from interface java.util.stream.LongStream

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

Methods inherited from interface java.util.stream.BaseStream

close, isParallel

Method Detail

filter

LongCacheStream filter(LongPredicate predicate)

Specified by:

filter in interface LongStream

Returns:

the new cache long stream

filter

default LongCacheStream filter(SerializableLongPredicate predicate)

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the new cache long stream

map

LongCacheStream map(LongUnaryOperator mapper)

Specified by:

map in interface LongStream

Returns:

the new cache long stream

map

default LongCacheStream map(SerializableLongUnaryOperator mapper)

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the new cache long stream

mapToObj

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

Specified by:

mapToObj in interface LongStream

Returns:

the new cache stream

mapToObj

default <U> CacheStream<U> mapToObj(SerializableLongFunction<? extends U> mapper)

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

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(LongToIntFunction mapper)

Specified by:

mapToInt in interface LongStream

Returns:

the new cache int stream

mapToInt

default IntCacheStream mapToInt(SerializableLongToIntFunction mapper)

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the new cache int stream

mapToDouble

DoubleCacheStream mapToDouble(LongToDoubleFunction mapper)

Specified by:

mapToDouble in interface LongStream

Returns:

the new cache double stream

mapToDouble

default DoubleCacheStream mapToDouble(SerializableLongToDoubleFunction mapper)

Same as mapToDouble(LongToDoubleFunction) except that the LongToLongFunction must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the new cache double stream

flatMap

LongCacheStream flatMap(LongFunction<? extends LongStream> mapper)

Specified by:

flatMap in interface LongStream

Returns:

the new cache long stream

flatMap

default LongCacheStream flatMap(SerializableLongFunction<? extends LongStream> mapper)

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the new cache long stream

distinct

LongCacheStream distinct()

Specified by:

distinct in interface LongStream

Returns:

the new cache long stream

sorted

LongCacheStream sorted()

Specified by:

sorted in interface LongStream

Returns:

the new cache long stream

peek

LongCacheStream peek(LongConsumer action)

Specified by:

peek in interface LongStream

Returns:

the new cache long stream

peek

default LongCacheStream peek(SerializableLongConsumer action)

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the new cache long stream

limit

LongCacheStream limit(long maxSize)

Specified by:

limit in interface LongStream

Returns:

the new cache long stream

skip

LongCacheStream skip(long n)

Specified by:

skip in interface LongStream

Returns:

the new cache long stream

forEach

default void forEach(SerializableLongConsumer action)

Same as LongStream.forEach(LongConsumer) except that the LongConsumer must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

forEach

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

Same as LongStream.forEach(LongConsumer) except that it takes an ObjLongConsumer 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

default <K,V> void forEach(SerializableObjLongConsumer<Cache<K,V>> action)

Same as forEach(ObjLongConsumer) 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

default long reduce(long identity,
                    SerializableLongBinaryOperator op)

Same as LongStream.reduce(long, LongBinaryOperator) except that the LongBinaryOperator must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

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

default OptionalLong reduce(SerializableLongBinaryOperator op)

Same as LongStream.reduce(LongBinaryOperator) except that the LongBinaryOperator must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

Parameters:

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

Returns:

the result of the reduction

collect

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

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

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

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

default boolean anyMatch(SerializableLongPredicate predicate)

Same as LongStream.anyMatch(LongPredicate) except that the LongPredicate must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

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

default boolean allMatch(SerializableLongPredicate predicate)

Same as LongStream.allMatch(LongPredicate) except that the LongPredicate must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

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

default boolean noneMatch(SerializableLongPredicate predicate)

Same as LongStream.noneMatch(LongPredicate) except that the LongPredicate must also implement Serializable.

This method will be used automatically by lambdas, which prevents users from having to manually cast to a Serializable lambda.

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<Long> boxed()

Specified by:

boxed in interface LongStream

Returns:

the new cache stream containing longs

asDoubleStream

DoubleCacheStream asDoubleStream()

Specified by:

asDoubleStream in interface LongStream

Returns:

the cache double stream

sequential

LongCacheStream sequential()

Specified by:

sequential in interface BaseStream<Long,LongStream>

Specified by:

sequential in interface LongStream

Returns:

a sequential cache long stream

parallel

LongCacheStream parallel()

Specified by:

parallel in interface BaseStream<Long,LongStream>

Specified by:

parallel in interface LongStream

Returns:

a parallel cache long stream

unordered

LongCacheStream unordered()

Specified by:

unordered in interface BaseStream<Long,LongStream>

Returns:

an unordered cache long stream

onClose

LongCacheStream onClose(Runnable closeHandler)

Specified by:

onClose in interface BaseStream<Long,LongStream>

Returns:

a cache long stream with the handler applied