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