MqttSubscriptionManager constructor

MqttSubscriptionManager(
  1. dynamic _connectionHandler,
  2. dynamic _clientEventBus
)

Creates a new instance of a SubscriptionsManager that uses the specified connection to manage subscriptions.

Implementation

MqttSubscriptionManager(this._connectionHandler, this._clientEventBus) {
  _connectionHandler.registerForMessage(
      MqttMessageType.subscribeAck, confirmSubscription);
  _connectionHandler.registerForMessage(
      MqttMessageType.unsubscribeAck, confirmUnsubscribe);
  // Start listening for published messages
  _clientEventBus.on<MqttMessageReceived>().listen(publishMessageReceived);
  _clientEventBus.on<MqttResubscribe>().listen(_resubscribe);
}