getSubscriptionStatus method

MqttSubscriptionStatus getSubscriptionStatus(
  1. MqttSubscription subscription
)

Gets the current status of a subscription.

Implementation

MqttSubscriptionStatus getSubscriptionStatus(MqttSubscription subscription) {
  var status = MqttSubscriptionStatus.doesNotExist;
  if (subscriptions.containsKey(subscription.topic.rawTopic)) {
    status = MqttSubscriptionStatus.active;
  }
  for (final topics in pendingSubscriptions.values) {
    for (final subTopic in topics) {
      if (subTopic == subscription) {
        status = MqttSubscriptionStatus.pending;
      }
    }
  }
  return status;
}