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