vertx / io.vertx.ext.reactivestreams / ReactiveReadStream

# ReactiveReadStream

`interface ReactiveReadStream<T : Any> : ReadStream<T>, Subscriber<T>`

A Vert.x read stream that also implements reactive streams subscriber interface.

Author
Tim Fox

### Properties

DEFAULT_BATCH_SIZE | `static val DEFAULT_BATCH_SIZE: Long` Default batch size

### Functions

endHandler | `abstract fun endHandler(endHandler: Handler<Void>): ReactiveReadStream<T>`
exceptionHandler | `abstract fun exceptionHandler(handler: Handler<Throwable>): ReactiveReadStream<T>`
handler | `abstract fun handler(handler: Handler<T>): ReactiveReadStream<T>`
pause | `abstract fun pause(): ReactiveReadStream<T>`
readStream | `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
resume | `abstract fun resume(): ReactiveReadStream<T>`