public class IOStreams extends Streams
Modifier and Type | Method and Description |
---|---|
static <SRC,IN> Stream<IN> |
decode(Codec<SRC,IN,?> codec,
org.reactivestreams.Publisher<? extends SRC> publisher)
|
static <KEY,VALUE> |
persistentMap(String name)
A Persistent Map is a
MapStream that fulfill both the Map and the Stream contract. |
static <KEY,VALUE> |
persistentMap(String name,
boolean deleteOnExit)
A Persistent Map is a
MapStream that fulfill both the Map and the Stream contract. |
static <KEY,VALUE> |
persistentMapReader(String name)
A Persistent Map is a
MapStream that fulfill both the Map and the Stream contract. |
await, await, await, await, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, combineLatest, concat, concat, concat, concat, concat, concat, concat, concat, concat, create, createWith, createWith, createWith, defer, empty, fail, from, from, from, from, generate, join, join, join, join, join, join, join, join, join, just, just, just, just, just, just, just, just, merge, merge, merge, merge, merge, merge, merge, merge, merge, never, period, period, period, period, period, period, period, period, range, switchOnNext, switchOnNext, switchOnNext, switchOnNext, timer, timer, timer, timer, wrap, zip, zip, zip, zip, zip, zip, zip, zip, zip
public static <KEY,VALUE> MapStream<KEY,VALUE> persistentMap(String name)
MapStream
that fulfill both the Map and the Stream contract.
Effectively it will act a store to be shared by consumers such as BiStreams
operators.
Implementing the MapStream contract means that subscribers will have the ability to listen for put, putAll, clear
and delete operations.
A persistent map is read/write capable and will use an internal cached map for read operations. This cache will be
updated when an operation has been notified. Read-only persistent map can be created with persistentMapReader(String)
.
By default a persistentMap survives any application shutdown up to the latest written data. For a given name,
the store is going to be located under the same default base location.KEY
- the type of the key used to identify stored valuesVALUE
- the type of the payload storedname
- The identified name for the data storepublic static <KEY,VALUE> MapStream<KEY,VALUE> persistentMap(String name, boolean deleteOnExit)
MapStream
that fulfill both the Map and the Stream contract.
Effectively it will act a store to be shared by consumers such as BiStreams
operators.
Implementing the MapStream contract means that subscribers will have the ability to listen for put, putAll, clear
and delete operations.
A persistent map is read/write capable and will use an internal cached map for read operations. This cache will be
updated when an operation has been notified. Read-only persistent map can be created with persistentMapReader(String)
.
By default a persistentMap survives any application shutdown up to the latest written data. For a given name,
the store is going to be located under the same default base location.KEY
- the type of the key used to identify stored valuesVALUE
- the type of the payload storedname
- The identified name for the data storedeleteOnExit
- Make a persistent store transient, useful for producer queues coupled with persistent map readers.public static <KEY,VALUE> MapStream<KEY,VALUE> persistentMapReader(String name)
MapStream
that fulfill both the Map and the Stream contract.
Effectively it will act a store to be shared by consumers such as BiStreams
operators.
Implementing the MapStream contract means that subscribers will have the ability to listen for put, putAll, clear
and delete operations.
A persistent map reader is read capable only and will use an internal cached map for read/write operations. This cache will be
updated when an operation has been notified. Read/Write persistent map can be created with persistentMap(String)
.
By default a persistentMap survives any application shutdown up to the latest written data. For a given name,
the store is going to be located under the same default base location.KEY
- the type of the key used to identify stored valuesVALUE
- the type of the payload storedname
- The identified name for the data storepublic static <SRC,IN> Stream<IN> decode(Codec<SRC,IN,?> codec, org.reactivestreams.Publisher<? extends SRC> publisher)
Codec
to decode any SRC
data published by the publisher
reference.
Some codec might result into N signals for one SRC data.SRC
- The type of the origin valueIN
- The type of the decoded valuecodec
- the codec decoder is going to be used to scan the incoming SRC
datapublisher
- The data stream publisher we want to decodeCopyright © 2017. All rights reserved.