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.