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>