Method processStreamEvent

src/browser/stores/WorkspaceStore.ts:4242–4433

(
    workspaceId: string,
    aggregator: StreamingMessageAggregator,
    data: WorkspaceChatMessage
  )

  }

  private processStreamEvent(
    workspaceId: string,
    aggregator: StreamingMessageAggregator,
    data: WorkspaceChatMessage
  ): void {
    // Handle special events first
    if (isStreamError(data)) {
      const transient = this.assertChatTransientState(workspaceId);

      // Suppress side effects during buffered replay (we're just hydrating UI state), but allow
      // live errors to trigger mux-gateway session-expired handling even before we're "caught up".
      // In particular, mux-gateway 401s can surface as a pre-stream stream-error (before any
      // stream-start) during startup/reconnect.
      const allowSideEffects = !transient.replayingHistory;

      applyWorkspaceChatEventToAggregator(aggregator, data, { allowSideEffects });

      // stream-error is a terminal stream event, just like stream-end/stream-abort.
      // Mirror their cleanup so subscribers don't see stale streaming stats from the
      // failed stream — applyWorkspaceChatEventToAggregator already cleared token
      // state; we now flush any pending coalesced bump and invalidate the
      // streamingStatsStore cache so useWorkspaceStreamingStats returns null.
      this.cancelPendingIdleBump(workspaceId);
      this.cancelPendingStreamingBump(workspaceId);
      this.states.bump(workspaceId);
      this.streamingStatsStore.bump(workspaceId);
      return;
    }

    if (isDeleteMessage(data)) {
      applyWorkspaceChatEventToAggregator(aggregator, data);
      this.cleanupStaleLiveToolState(workspaceId, aggregator);
      this.states.bump(workspaceId);
      this.checkAndBumpRecencyIfChanged();
      this.usageStore.bump(workspaceId);
      this.consumerManager.scheduleCalculation(workspaceId, aggregator);
      return;
    }

    if (isBashOutputEvent(data)) {
      if (data.text.length === 0) return;

      const transient = this.assertChatTransientState(workspaceId);

      const prev = transient.liveBashOutput.get(data.toolCallId);
      const next = appendLiveBashOutputChunk(
        prev,
        { text: data.text, isError: data.isError },
        BASH_TRUNCATE_MAX_TOTAL_BYTES
      );

      // Avoid unnecessary re-renders if this event didn't change the stored state.
      if (next === prev) return;

      transient.liveBashOutput.set(data.toolCallId, next);

      // High-frequency: throttle UI updates like other delta-style events.
      this.scheduleIdleStateBump(workspaceId);