proxyMessageFlow

open override val proxyMessageFlow: Flow<MqttClientProxyMessage>(source)

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