navigation-ux-synchronization-mqtt/com.mapbox.dash.synchronization.mqtt/MqttCommunicator

MqttCommunicator

@RestrictTo(value = [RestrictTo.Scope.LIBRARY_GROUP_PREFIX])
class MqttCommunicator(brokerUrl: String, scope: CoroutineScope, retrier: Retrier)

Constructors

Link copied to clipboard
constructor(brokerUrl: String, scope: CoroutineScope, retrier: Retrier)

Properties

Link copied to clipboard
val client: IMqttClient

Functions

Link copied to clipboard
fun connect()
Link copied to clipboard
fun disconnect()
Link copied to clipboard
fun emitToQueue(requireBeingConnected: Boolean = true, shouldRetry: Boolean = false, action: () -> Boolean)