Method createStallWatchdog

src/browser/stores/WorkspaceStore.ts:3019–3059

* Creates a stall watchdog that aborts the attempt when no events arrive * within the configured timeout. Call start() only after the subscription * connection is established so handshake latency isn't misclassified as * stream silence.

(
    attemptController: AbortController,
    label: string
  )

   * stream silence.
   */
  private createStallWatchdog(
    attemptController: AbortController,
    label: string
  ): { markEvent: () => void; start: () => void; stop: () => void } {
    let lastEventAt = Date.now();
    let interval: ReturnType<typeof setInterval> | null = null;

    return {
      markEvent: () => {
        lastEventAt = Date.now();
      },
      start: () => {
        if (interval != null) {
          return;
        }

        lastEventAt = Date.now();
        interval = setInterval(() => {
          if (attemptController.signal.aborted) {
            return;
          }

          const elapsedMs = Date.now() - lastEventAt;
          if (elapsedMs < SUBSCRIPTION_STALL_TIMEOUT_MS) {
            return;
          }

          console.warn(
            `[WorkspaceStore] ${label} stalled (no events for ${elapsedMs}ms); retrying...`
          );
          attemptController.abort();
        }, SUBSCRIPTION_STALL_CHECK_INTERVAL_MS);
      },
      stop: () => {
        if (interval != null) {
          clearInterval(interval);
          interval = null;
        }
      },
    };
  }

  private async runTerminalActivitySubscription(controller: AbortController): Promise<void> {
    const signal = controller.signal;