vertx / io.vertx.ext.reactivestreams / ReactiveReadStream / readStream

readStream

open static fun <T : Any> readStream(): ReactiveReadStream<T>

Create a reactive read stream

Return
the stream

open static fun <T : Any> readStream(batchSize: Long): ReactiveReadStream<T>

Create a reactive read stream specifying batch size

Parameters

batchSize - the batch size

Return
the stream