MqttTopicFilter constructor

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

Construction

Implementation

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