Package | Description |
---|---|
reactor.rx |
Streams are reactive components derived from Reactive Extensions and implementing Reactive Streams specification.
|
reactor.rx.action.pair | |
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> |
IOStreams.persistentMap(String name)
A Persistent Map is a
MapStream that fulfill both the Map and the Stream contract. |
static <KEY,VALUE> |
IOStreams.persistentMap(String name,
boolean deleteOnExit)
A Persistent Map is a
MapStream that fulfill both the Map and the Stream contract. |
static <KEY,VALUE> |
IOStreams.persistentMapReader(String name)
A Persistent Map is a
MapStream that fulfill both the Map and the Stream contract. |
Modifier and Type | Method and Description |
---|---|
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.scanByKey(org.reactivestreams.Publisher<Tuple2<KEY,VALUE>> publisher,
MapStream<KEY,VALUE> mapStream,
BiFunction<VALUE,VALUE,VALUE> accumulator) |
Constructor and Description |
---|
ReduceByKeyAction(BiFunction<? super V,? super V,V> fn,
MapStream<K,V> mapStream) |
ScanByKeyAction(BiFunction<? super V,? super V,V> fn,
MapStream<K,V> mapStream) |
Modifier and Type | Class and Description |
---|---|
class |
ChronicleReaderStream<K,V>
Implementation of a
Dispatcher that uses a IndexedChronicle to
queue tasks to execute. |
class |
ChronicleStream<K,V> |
Copyright © 2017. All rights reserved.