Function snapshotSideQuestionLiveStream

src/node/services/sideQuestionService.ts:151–164

(
  liveStream: ReturnType<AIService["getStreamInfo"]>
)

 * existing `onChat` subscription.
 */
export function snapshotSideQuestionLiveStream(
  liveStream: ReturnType<AIService["getStreamInfo"]>
): ReturnType<AIService["getStreamInfo"]> {
  return liveStream
    ? {
        ...liveStream,
        // Freeze the visible-at-/btw part list before any awaited I/O.
        // StreamManager mutates this array as new main-agent chunks arrive;
        // the side-question prompt must line up with the interruption offset
        // captured at this exact moment.
        parts: liveStream.parts.map((part) => ({ ...part })),
      }
    : undefined;
}

export async function askSideQuestion(
  opts: AskSideQuestionOptions