published property

Stream<MqttPublishMessage>? get published

Published message stream. A publish message is added to this stream on completion of the message publishing protocol for a Qos level.

Attach listeners only after connect has been called.

Implementation

Stream<MqttPublishMessage>? get published =>
    publishingManager?.published.stream;