pipeToAwait
suspend fun PgChannel.pipeToAwait(dst: WriteStream<String>): Unit
Suspending version of method io.vertx.pgclient.pubsub.PgChannel.pipeTo