MQTTRepositoryImpl

Constructors

constructor(radioConfigRepository: RadioConfigRepository, nodeRepository: NodeRepository, buildConfigProvider: BuildConfigProvider, dispatchers: CoroutineDispatchers)

open override val connectionState: StateFlow<ConnectionState>

Observable MQTT connection lifecycle state (DISCONNECTED → CONNECTING → CONNECTED → RECONNECTING).

open override val proxyMessageFlow: Flow<MqttClientProxyMessage>

A flow of incoming messages from the subscribed MQTT topics. Connecting/subscribing is initiated when this flow is collected.

open override fun disconnect()

Disconnects the MQTT client and cleans up resources.

open override fun publish(topic: String, data: ByteArray, retained: Boolean)

Publishes a message to the given MQTT topic.