MqttClientTopicFilter constructor

MqttClientTopicFilter(String _topic, Stream<List<MqttReceivedMessage<MqttMessage?>>?>? _clientUpdates)

Construction

Implementation

MqttClientTopicFilter(this._topic, this._clientUpdates) {
  _subscriptionTopic = SubscriptionTopic(_topic);
  _clientUpdates!.listen(_topicIn);
  _updates =
      StreamController<List<MqttReceivedMessage<MqttMessage?>>>.broadcast(
          sync: true);
}