SubscriptionsManager constructor

SubscriptionsManager(
  1. IMqttConnectionHandler? connectionHandler,
  2. PublishingManager? publishingManager,
  3. EventBus? _clientEventBus
)

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

Implementation

SubscriptionsManager(
    this.connectionHandler, this.publishingManager, this._clientEventBus) {
  connectionHandler!
      .registerForMessage(MqttMessageType.subscribeAck, confirmSubscription);
  connectionHandler!
      .registerForMessage(MqttMessageType.unsubscribeAck, confirmUnsubscribe);
  // Start listening for published messages and re subscribe events.
  _clientEventBus!.on<MessageReceived>().listen(publishMessageReceived);
  _clientEventBus!.on<Resubscribe>().listen(_resubscribe);
}