removeAllSubscriptions method

Future<List<RealtimeSubscription>> removeAllSubscriptions()

Closes and removes all subscriptions and returns a list of removed subscriptions and their errors.

Implementation

Future<List<RealtimeSubscription>> removeAllSubscriptions() async {
  final allSubs = [...getSubscriptions()];
  final allSubsFutures = allSubs.map((sub) => removeSubscription(sub));
  final allRemovedSubs = await Future.wait(allSubsFutures);
  final removed = <RealtimeSubscription>[];
  for (var i = 0; i < allRemovedSubs.length; i++) {
    removed.add(allSubs[i]);
  }
  return removed;
}