unsubscribeAllFor method

Future<void> unsubscribeAllFor({ required Client client, required MCPUIRuntime runtime, required String ownerKey, })

Unsubscribes every resource associated with ownerKey. Used by the orchestrator's closeApp path to prevent leaked subscriptions.

Implementation

Future<void> unsubscribeAllFor({
  required Client client,
  required MCPUIRuntime runtime,
  required String ownerKey,
}) async {
  final uris = _active[ownerKey];
  if (uris == null || uris.isEmpty) return;
  for (final uri in List<String>.from(uris)) {
    try {
      await unsubscribe(
        client: client,
        runtime: runtime,
        uri: uri,
        ownerKey: ownerKey,
      );
    } catch (e) {
      _logger.warn(
          'unsubscribeAllFor: unsubscribe failed',
          {
            'uri': uri,
            'ownerKey': ownerKey,
          },
          e);
    }
  }
}