vertx / io.vertx.kotlin.cassandra / io.vertx.cassandra.CassandraRowStream

Extensions for io.vertx.cassandra.CassandraRowStream

pipeToAwait

suspend fun CassandraRowStream.pipeToAwait(dst: WriteStream<Row>): Unit

Suspending version of method io.vertx.cassandra.CassandraRowStream.pipeTo