vertx / io.vertx.kotlin.mqtt / io.vertx.mqtt.MqttServer

Extensions for io.vertx.mqtt.MqttServer

closeAwait

suspend fun MqttServer.closeAwait(): Unit

Suspending version of method io.vertx.mqtt.MqttServer.close

listenAwait

suspend fun MqttServer.listenAwait(port: Int, host: String): MqttServer
suspend fun MqttServer.listenAwait(port: Int): MqttServer
suspend fun MqttServer.listenAwait(): MqttServer

Suspending version of method io.vertx.mqtt.MqttServer.listen