Method destroySubscribersForAgent

app/src/utils/streamManager.ts:222–244

* Destroy all subscribers for an agent. * Called when an agent stops.

(agentId: string)

   * Called when an agent stops.
   */
  public destroySubscribersForAgent(agentId: string): void {
    const keysToDelete: string[] = [];

    const router = TranscriptionRouter.getInstance();
    for (const [key, subscriber] of this.subscribers) {
      if (key.startsWith(`${agentId}:`)) {
        // Remove from transcription service
        const service = router.getActiveService(subscriber.streamType);
        if (service) {
          service.removeSubscriber(subscriber);
        }

        subscriber.destroy();
        keysToDelete.push(key);
      }
    }

    keysToDelete.forEach(key => this.subscribers.delete(key));

    if (keysToDelete.length > 0) {
      Logger.debug("StreamManager", `Destroyed ${keysToDelete.length} subscriber(s) for agent ${agentId}`);
    }
  }

  public addListener(listener: StreamListener): void { this.listeners.add(listener); listener(this.getCurrentState()); }
  public removeListener(listener: StreamListener): void { this.listeners.delete(listener); }