vertx / io.vertx.kotlin.coroutines / io.vertx.core.streams.ReadStream

Extensions for io.vertx.core.streams.ReadStream

toChannel

fun <T> ReadStream<T>.toChannel(vertx: Vertx, capacity: Int = 256): ReceiveChannel<T>
fun <T> ReadStream<T>.toChannel(context: Context, capacity: Int = 256): ReceiveChannel<T>

Adapts the current read stream to Kotlin ReceiveChannel.