Method subscribeToStats

src/browser/stores/WorkspaceStore.ts:1575–1625

* Subscribe to backend timing stats snapshots for a workspace.

(workspaceId: string)

   */

  private subscribeToStats(workspaceId: string): void {
    if (!this.client) {
      return;
    }

    // Only subscribe for registered workspaces when we have at least one UI consumer.
    if (!this.isWorkspaceRegistered(workspaceId)) {
      return;
    }
    if ((this.statsListenerCounts.get(workspaceId) ?? 0) <= 0) {
      return;
    }

    // Skip if already subscribed
    if (this.statsUnsubscribers.has(workspaceId)) {
      return;
    }

    const controller = new AbortController();
    const { signal } = controller;
    let iterator: AsyncIterator<WorkspaceStatsSnapshot> | null = null;

    (async () => {
      try {
        const subscribedIterator = await this.client!.workspace.stats.subscribe(
          { workspaceId },
          { signal }
        );
        iterator = subscribedIterator;

        for await (const snapshot of subscribedIterator) {
          if (signal.aborted) break;
          queueMicrotask(() => {
            if (signal.aborted) {
              return;
            }
            this.workspaceStats.set(workspaceId, snapshot);
            this.statsStore.bump(workspaceId);
          });
        }
      } catch (error) {
        if (signal.aborted || isAbortError(error)) return;
        console.warn(`[WorkspaceStore] Error in stats subscription for ${workspaceId}:`, error);
      }
    })();

    this.statsUnsubscribers.set(workspaceId, () => {
      controller.abort();
      void iterator?.return?.();
    });
  }

  /**
   * Cancel any pending idle state bump for a workspace.