vertx / io.vertx.kotlin.mqtt / io.vertx.mqtt.MqttClient

### Extensions for io.vertx.mqtt.MqttClient

connectAwait | `suspend fun MqttClient.connectAwait(port: Int, host: String): MqttConnAckMessage` `suspend fun MqttClient.connectAwait(port: Int, host: String, serverName: String): MqttConnAckMessage` Suspending version of method io.vertx.mqtt.MqttClient.connect
disconnectAwait | `suspend fun MqttClient.disconnectAwait(): Unit` Suspending version of method io.vertx.mqtt.MqttClient.disconnect
publishAwait | `suspend fun MqttClient.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int` Suspending version of method io.vertx.mqtt.MqttClient.publish
subscribeAwait | `suspend fun MqttClient.subscribeAwait(topic: String, qos: Int): Int` `suspend fun MqttClient.subscribeAwait(topics: Map<String, Int>): Int` Suspending version of method io.vertx.mqtt.MqttClient.subscribe
unsubscribeAwait | `suspend fun MqttClient.unsubscribeAwait(topic: String): Int` Suspending version of method io.vertx.mqtt.MqttClient.unsubscribe