cancelModuleSubscriptions method

void cancelModuleSubscriptions(String moduleId)

Cancel all subscriptions from a module

Implementation

void cancelModuleSubscriptions(String moduleId) {
  int count = 0;
  for (final subs in _subscriptions.values) {
    subs.removeWhere((s) {
      if (s.subscriberModuleId == moduleId) {
        s.cancel();
        count++;
        return true;
      }
      return false;
    });
  }

  // Also clean up signal subscriptions
  for (final subs in _signalSubscriptions.values) {
    subs.removeWhere((s) {
      if (s.subscriberModuleId == moduleId) {
        s.cancel();
        count++;
        return true;
      }
      return false;
    });
  }
  AirLogger.debug(
    'Cancelled subscriptions for module',
    context: {'moduleId': moduleId, 'count': count},
  );
}