Package | Description |
---|---|
com.tangosol.util.stream |
Contains classes to support functional-style operations on remote streams of elements, such as map-reduce transformations on collections.
|
Modifier and Type | Method and Description |
---|---|
RemoteIntStream |
RemoteIntStream.filter(IntPredicate predicate)
Returns a stream consisting of the elements of this stream that match the given predicate.
|
default RemoteIntStream |
RemoteIntStream.filter(Remote.IntPredicate predicate)
Returns a stream consisting of the elements of this stream that match the given predicate.
|
RemoteIntStream |
RemoteIntStream.flatMap(IntFunction<? extends IntStream> mapper)
Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
|
default RemoteIntStream |
RemoteIntStream.flatMap(Remote.IntFunction<? extends IntStream> mapper)
Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element.
|
RemoteIntStream |
RemoteStream.flatMapToInt(Function<? super T,? extends IntStream> mapper)
Returns an
IntStream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element. |
default RemoteIntStream |
RemoteStream.flatMapToInt(Remote.Function<? super T,? extends IntStream> mapper)
Returns an
IntStream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the provided mapping function to each element. |
RemoteIntStream |
RemoteIntStream.map(IntUnaryOperator mapper)
Returns a stream consisting of the results of applying the given function to the elements of this stream.
|
default RemoteIntStream |
RemoteIntStream.map(Remote.IntUnaryOperator mapper)
Returns a stream consisting of the results of applying the given function to the elements of this stream.
|
RemoteIntStream |
RemoteDoubleStream.mapToInt(DoubleToIntFunction mapper)
Returns an
IntStream consisting of the results of applying the given function to the elements of this stream. |
RemoteIntStream |
RemoteLongStream.mapToInt(LongToIntFunction mapper)
Returns an
IntStream consisting of the results of applying the given function to the elements of this stream. |
default RemoteIntStream |
RemoteDoubleStream.mapToInt(Remote.DoubleToIntFunction mapper)
Returns an
IntStream consisting of the results of applying the given function to the elements of this stream. |
default RemoteIntStream |
RemoteLongStream.mapToInt(Remote.LongToIntFunction mapper)
Returns an
IntStream consisting of the results of applying the given function to the elements of this stream. |
default RemoteIntStream |
RemoteStream.mapToInt(Remote.ToIntFunction<? super T> mapper)
Returns an
IntStream consisting of the results of applying the given function to the elements of this stream. |
RemoteIntStream |
RemoteStream.mapToInt(ToIntFunction<? super T> mapper)
Returns an
IntStream consisting of the results of applying the given function to the elements of this stream. |
default RemoteIntStream |
RemoteStream.mapToInt(ValueExtractor<? super T,? extends Number> mapper)
Returns an
IntStream consisting of the results of applying the given extractor to the elements of this stream. |
RemoteIntStream |
RemoteIntStream.parallel() |
RemoteIntStream |
RemoteIntStream.peek(IntConsumer action)
Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
|
default RemoteIntStream |
RemoteIntStream.peek(Remote.IntConsumer action)
Returns a stream consisting of the elements of this stream, additionally performing the provided action on each element as elements are consumed from the resulting stream.
|
RemoteIntStream |
RemoteIntStream.sequential() |
static <T extends Number> |
RemoteStream.toIntStream(RemoteStream<T> stream)
Convert stream of numbers into
RemoteIntStream . |