Package | Description |
---|---|
com.tangosol.util.function |
Contains Functional interfaces allowing remote execution of lambda expressions and method references.
|
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 |
---|---|
default Remote.BiConsumer<T,U> |
Remote.BiConsumer.andThen(Remote.BiConsumer<? super T,? super U> after)
Returns a composed
BiConsumer that performs, in sequence, this operation followed by the after operation. |
static <T,U> Remote.BiConsumer<T,U> |
Remote.biConsumer(Remote.BiConsumer<T,U> biConsumer)
Capture serializable BiConsumer.
|
Modifier and Type | Method and Description |
---|---|
default Remote.BiConsumer<T,U> |
Remote.BiConsumer.andThen(Remote.BiConsumer<? super T,? super U> after)
Returns a composed
BiConsumer that performs, in sequence, this operation followed by the after operation. |
static <T,U> Remote.BiConsumer<T,U> |
Remote.biConsumer(Remote.BiConsumer<T,U> biConsumer)
Capture serializable BiConsumer.
|
Modifier and Type | Method and Description |
---|---|
default <R> R |
RemoteStream.collect(Remote.Supplier<R> supplier, Remote.BiConsumer<R,? super T> accumulator, Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this stream.
|
default <R> R |
RemoteStream.collect(Remote.Supplier<R> supplier, Remote.BiConsumer<R,? super T> accumulator, Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this stream.
|
default <R> R |
RemoteDoubleStream.collect(Remote.Supplier<R> supplier, Remote.ObjDoubleConsumer<R> accumulator, Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this stream.
|
default <R> R |
RemoteIntStream.collect(Remote.Supplier<R> supplier, Remote.ObjIntConsumer<R> accumulator, Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this stream.
|
default <R> R |
RemoteLongStream.collect(Remote.Supplier<R> supplier, Remote.ObjLongConsumer<R> accumulator, Remote.BiConsumer<R,R> combiner)
Performs a mutable reduction operation on the elements of this stream.
|
static <T,A,R> RemoteCollector<T,A,R> |
RemoteCollector.of(Remote.Supplier<A> supplier, Remote.BiConsumer<A,T> accumulator, Remote.BinaryOperator<A> combiner, Remote.Function<A,R> finisher, Collector.Characteristics... characteristics)
Returns a new
Collector described by the given supplier , accumulator , combiner , and finisher functions. |
static <T,R> RemoteCollector<T,R,R> |
RemoteCollector.of(Remote.Supplier<R> supplier, Remote.BiConsumer<R,T> accumulator, Remote.BinaryOperator<R> combiner, Collector.Characteristics... characteristics)
Returns a new
Collector described by the given supplier , accumulator , and combiner functions. |