suspend fun AmqpReceiver.closeAwait(): Unit
Suspending version of method io.vertx.amqp.AmqpReceiver.close |
|
suspend fun AmqpReceiver.pipeToAwait(dst: WriteStream<AmqpMessage>): Unit
Suspending version of method io.vertx.amqp.AmqpReceiver.pipeTo |