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
Return
the stream