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

Extensions for io.vertx.core.streams.WriteStream

toChannel

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

Adapts the current write stream to Kotlin SendChannel.