core-data/org.meshtastic.core.data.manager/MqttManagerImpl

MqttManagerImpl

class MqttManagerImpl(mqttRepository: MQTTRepository, packetHandler: PacketHandler, serviceStateWriter: ServiceStateWriter, nodeRepository: NodeRepository, scope: CoroutineScope) : MqttManager(source)

Constructors

MqttManagerImpl

constructor(mqttRepository: MQTTRepository, packetHandler: PacketHandler, serviceStateWriter: ServiceStateWriter, nodeRepository: NodeRepository, scope: CoroutineScope)

Properties

mqttConnectionState

open override val mqttConnectionState: StateFlow<MqttConnectionState>

open override val proxyActive: StateFlow<Boolean>

Functions

handleMqttProxyMessage

open override fun handleMqttProxyMessage(message: MqttClientProxyMessage)

open suspend override fun probe(address: String, tlsEnabled: Boolean, username: String?, password: String?): MqttProbeStatus

open override fun startProxy(enabled: Boolean, proxyToClientEnabled: Boolean)

open override fun stop()