subscribeForWaiting method

void subscribeForWaiting()

Implementation

void subscribeForWaiting() async {
  //var indexesToRemove = List<int>.empty(growable: true);
  var tempSubscriptions =
      List.from(RTListener.clientInstance!.waitingSubscriptions);

  try {
    for (var waitingSubscription in tempSubscriptions) {
      var data = waitingSubscription.data;
      var name = data!['name'] as String;
      var options = waitingSubscription.options;

      if (name == SubscriptionNames.PUB_SUB_MESSAGES.toShortString() ||
          name == SubscriptionNames.PUB_SUB_COMMANDS.toShortString() ||
          name == SubscriptionNames.PUB_SUB_USERS.toShortString() ||
          options!['channel'] as String == _channelName) {
        waitingSubscription.subscribe();

        ///TODO ADD DELETE FROM WAITING SUB
      }
    }
    RTListener.clientInstance!.waitingSubscriptions.clear();
  } catch (ex) {
    if (kDebugMode) {
      print('EXCEPTION IN SUBSCRIBE FOR WAITING SUBSCRIPTIONS');
    }
  }
}