interface ReactiveReadStream<T : Any> : ReadStream<T>, Subscriber<T>
A Vert.x read stream that also implements reactive streams subscriber interface.
Author
Tim Fox
static val DEFAULT_BATCH_SIZE: Long
Default batch size |
abstract fun endHandler(endHandler: Handler<Void>): ReactiveReadStream<T> |
|
abstract fun exceptionHandler(handler: Handler<Throwable>): ReactiveReadStream<T> |
|
abstract fun handler(handler: Handler<T>): ReactiveReadStream<T> |
|
abstract fun pause(): ReactiveReadStream<T> |
|
open static fun <T : Any> readStream(): ReactiveReadStream<T>
Create a reactive read stream open static fun <T : Any> readStream(batchSize: Long): ReactiveReadStream<T>
Create a reactive read stream specifying batch size |
|
abstract fun resume(): ReactiveReadStream<T> |