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');
}
}
}