publishMessageReceived method

void publishMessageReceived(
  1. MessageReceived event
)

Publish message received

Implementation

void publishMessageReceived(MessageReceived event) {
  final topic = event.topic;
  final msg = MqttReceivedMessage<MqttMessage>(topic.rawTopic, event.message);
  _subscriptionNotifier.add([msg]);
}