Package | Description |
---|---|
reactor.rx.stream.io |
Stream implementations that provide for IO access, for instance read/read-write persisting streams |
Class and Description |
---|
ChronicleReaderStream
Implementation of a
Dispatcher that uses a IndexedChronicle to
queue tasks to execute. |
Copyright © 2017. All rights reserved.