| Package | Description |
|---|---|
| reactor.rx.stream.io |
Stream implementations that provide for IO access, for instance read/read-write persisting streams |
| Modifier and Type | Class and Description |
|---|---|
class |
ChronicleStream<K,V> |
| Modifier and Type | Field and Description |
|---|---|
protected static AtomicIntegerFieldUpdater<ChronicleReaderStream> |
ChronicleReaderStream.CONSUMER_UPDATER |
Copyright © 2016. All rights reserved.