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 |
|
suspend fun MqttClient.disconnectAwait(): Unit
Suspending version of method io.vertx.mqtt.MqttClient.disconnect |
|
suspend fun MqttClient.publishAwait(topic: String, payload: Buffer, qosLevel: MqttQoS, isDup: Boolean, isRetain: Boolean): Int
Suspending version of method io.vertx.mqtt.MqttClient.publish |
|
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 |
|
suspend fun MqttClient.unsubscribeAwait(topic: String): Int
Suspending version of method io.vertx.mqtt.MqttClient.unsubscribe |