fun <T> ReadStream<T>.toChannel(vertx: Vertx, capacity: Int = 256): ReceiveChannel<T>
Adapts the current read stream to Kotlin ReceiveChannel.
The channel can be used to receive the read stream items, the stream is paused when the channel is full and resumed when the channel is half empty.
vertx - the related vertx instance
capacity - the channel buffering capacity
fun <T> ReadStream<T>.toChannel(context: Context, capacity: Int = 256): ReceiveChannel<T>
Adapts the current read stream to Kotlin ReceiveChannel.
The channel can be used to receive the read stream items, the stream is paused when the channel is full and resumed when the channel is half empty.