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 |
---|---|
RemoteDoubleStream |
RemoteLongStream.asDoubleStream()
Returns a
DoubleStream consisting of the elements of this stream,
converted to double . |
RemoteDoubleStream |
RemoteIntStream.asDoubleStream()
Returns a
DoubleStream consisting of the elements of this stream,
converted to double . |
RemoteDoubleStream |
RemoteDoubleStream.filter(DoublePredicate predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
default RemoteDoubleStream |
RemoteDoubleStream.filter(Remote.DoublePredicate predicate)
Returns a stream consisting of the elements of this stream that match
the given predicate.
|
RemoteDoubleStream |
RemoteDoubleStream.flatMap(DoubleFunction<? extends DoubleStream> 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 RemoteDoubleStream |
RemoteDoubleStream.flatMap(Remote.DoubleFunction<? extends DoubleStream> 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.
|
RemoteDoubleStream |
RemoteStream.flatMapToDouble(Function<? super T,? extends DoubleStream> mapper)
Returns an
DoubleStream 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 RemoteDoubleStream |
RemoteStream.flatMapToDouble(Remote.Function<? super T,? extends DoubleStream> mapper)
Returns an
DoubleStream 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. |
RemoteDoubleStream |
RemoteDoubleStream.map(DoubleUnaryOperator mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
default RemoteDoubleStream |
RemoteDoubleStream.map(Remote.DoubleUnaryOperator mapper)
Returns a stream consisting of the results of applying the given
function to the elements of this stream.
|
RemoteDoubleStream |
RemoteIntStream.mapToDouble(IntToDoubleFunction mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
RemoteDoubleStream |
RemoteLongStream.mapToDouble(LongToDoubleFunction mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
default RemoteDoubleStream |
RemoteIntStream.mapToDouble(Remote.IntToDoubleFunction mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
default RemoteDoubleStream |
RemoteLongStream.mapToDouble(Remote.LongToDoubleFunction mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
default RemoteDoubleStream |
RemoteStream.mapToDouble(Remote.ToDoubleFunction<? super T> mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
RemoteDoubleStream |
RemoteStream.mapToDouble(ToDoubleFunction<? super T> mapper)
Returns a
DoubleStream consisting of the results of applying the
given function to the elements of this stream. |
default RemoteDoubleStream |
RemoteStream.mapToDouble(ValueExtractor<? super T,? extends Number> mapper)
Returns an
DoubleStream consisting of the results of applying the
given extractor to the elements of this stream. |
RemoteDoubleStream |
RemoteDoubleStream.parallel() |
RemoteDoubleStream |
RemoteDoubleStream.peek(DoubleConsumer 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 RemoteDoubleStream |
RemoteDoubleStream.peek(Remote.DoubleConsumer 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.
|
RemoteDoubleStream |
RemoteDoubleStream.sequential() |
static <T extends Number> |
RemoteStream.toDoubleStream(RemoteStream<T> stream)
Convert stream of numbers into
RemoteDoubleStream . |