Distillation

Date: Sep 16, 2026

• 🟡 (15:59) Responses stream construction uses demand-aware backpressure via waitForDemand() and resumeDemand; stream abort handling registers onStreamAbort with signal.addEventListener("abort", onStreamAbort, { once: true }) and later performs abort-listener cleanup.
• 🟡 (15:59) Responses streaming tracks multiple byte budgets, including retainedStateBytes, deferredBytes, transactionalBytes, hiddenRecallBytes against maxHiddenRecallBytes, and streamBytes against maxStreamBytes; exceeded limits throw SSEStreamLimitError.
• 🟡 (15:59) Recall continuation failures are categorized through RecallContinuationFailureCategory; visible categories include "principal_resource_limit" and "follow_up_setup", and existing RecallContinuationFailure instances are rethrown.
• 🟡 (15:59) Principal-stream handling tracks unresolvedToolIndices, identifies events resolving visible tools, and defers principal chunks until unresolved tool calls are cleared; deferred chunks are emitted through enqueuePrincipal(deferred.chunk, otherToolSeen).
• 🟡 (15:59) Recall execution explicitly rejects an unfinished principal response with the error text "incomplete recall principal cannot execute recall".
• 🟡 (15:59) Recall processing maintains transactional copies of stream state, including items: new Map(state.items), recall content lookup via recallAcc.content.findIndex(...), and restoration/update through state.items.set(recall.outputIndex, ...); committed processing clears buffered events using deferredEvents.length = 0.
• 🟡 (15:59) Follow-up continuation processing snapshots identity and recall state, including referenceIdentities: new Set(referenceIdentities) and contRecallInputs; it can buffer output with holdContinuation(...), release it with flushHeldContinuation(), and track the highest index through maximumOutputIndex = { value: -1 }.
• 🟡 (15:59) Continuation events are lifecycle-validated with validateResponseLifecycle(contState, ce, cparsed) and separately handle "response.output_item.added", "response.output_item.done", and items whose type === "function_call".
• 🟡 (15:59) Final output assembly creates finalOutput: Array<Record<string, unknown>>, merges raw item data from state.rawItems.get(index), and preserves raw array content using content: Array.isArray(raw?.content) ? raw.content : item.content.