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