Package | Description |
---|---|
reactor.fn |
This package contains the foundational abstractions on which Reactor's functional and reactive components are
built.
|
reactor.groovy.ext | |
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.pair | |
reactor.rx.action.transformation |
Modifier and Type | Method and Description |
---|---|
static <LEFT,RIGHT,V> |
Functions.pairFrom(Function<Tuple2<LEFT,RIGHT>,V> function)
Deprecated.
Wrap a given
Function that applies transformation to a Tuple2 into a PairFunction. |
Modifier and Type | Method and Description |
---|---|
static <LEFT,RIGHT,V> |
Functions.functionFrom(BiFunction<LEFT,RIGHT,V> pairFunction)
Deprecated.
Wrap a given
BiFunction that applies transformation to a Tuple2 into a Function Tuple2. |
Modifier and Type | Method and Description |
---|---|
static <T> Stream<T> |
StreamExtensions.mod(Stream<T> selfType,
BiFunction<T,T,T> other) |
static <K,V> Stream<Tuple2<K,V>> |
StreamExtensions.reduceByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
BiFunction<V,V,V> accumulator) |
static <K,V> Stream<Tuple2<K,V>> |
StreamExtensions.scanByKey(org.reactivestreams.Publisher<? extends Tuple2<K,V>> selfType,
BiFunction<V,V,V> accumulator) |
Modifier and Type | Method and Description |
---|---|
<A> Stream<A> |
Stream.reduce(A initial,
BiFunction<A,? super O,A> fn)
Reduce the values passing through this
Stream into an object A . |
Stream<O> |
Stream.reduce(BiFunction<O,O,O> fn)
Reduce the values passing through this
Stream into an object T . |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.reduceByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
<A> Stream<A> |
Stream.scan(A initial,
BiFunction<A,? super O,A> fn)
Scan the values passing through this
Stream into an object A . |
Stream<O> |
Stream.scan(BiFunction<O,O,O> fn)
Scan the values passing through this
Stream into an object A . |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
static <KEY,VALUE> |
BiStreams.scanByKeyOn(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
Map<KEY,VALUE> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<KEY,VALUE>> listener,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
Modifier and Type | Field and Description |
---|---|
protected BiFunction<? super V,? super V,V> |
ScanByKeyAction.fn |
Constructor and Description |
---|
ReduceByKeyAction(BiFunction<? super V,? super V,V> fn,
Map<K,V> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> mapListener) |
ReduceByKeyAction(BiFunction<? super V,? super V,V> fn,
MapStream<K,V> mapStream) |
ScanByKeyAction(BiFunction<? super V,? super V,V> fn,
Map<K,V> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> mapListener) |
ScanByKeyAction(BiFunction<? super V,? super V,V> fn,
MapStream<K,V> mapStream) |
Constructor and Description |
---|
ScanAction(A initial,
BiFunction<A,? super T,A> fn) |
Copyright © 2017. All rights reserved.