Package | Description |
---|---|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.pair | |
reactor.rx.stream | |
reactor.rx.stream.io |
Stream implementations that provide for IO access, for instance read/read-write persisting streams |
Modifier and Type | Method and Description |
---|---|
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.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) |
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.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 org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> |
ScanByKeyAction.mapListener |
Constructor and Description |
---|
ReduceByKeyAction(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,
Map<K,V> store,
org.reactivestreams.Publisher<? extends MapStream.Signal<K,V>> mapListener) |
Modifier and Type | Class and Description |
---|---|
static class |
MapStream.MutableSignal<K,V> |
Modifier and Type | Method and Description |
---|---|
static <K,V> MapStream.Signal<K,V> |
MapStream.Signal.create(MapStream.Operation op) |
static <K,V> MapStream.Signal<K,V> |
MapStream.Signal.create(MapStream.Operation op,
K key) |
static <K,V> MapStream.Signal<K,V> |
MapStream.Signal.create(MapStream.Operation op,
K key,
V value) |
static <K,V> MapStream.Signal<K,V> |
MapStream.Signal.create(MapStream.Operation op,
K key,
V value,
V previous) |
Modifier and Type | Method and Description |
---|---|
void |
ChronicleReaderStream.subscribe(org.reactivestreams.Subscriber<? super MapStream.Signal<K,V>> s) |
Copyright © 2017. All rights reserved.