Distillation

Date: Sep 16, 2026

• 🔴 (14:06) User supplied a continuation of pipeline.ts, with visible line anchors spanning 9623–10355, covering hidden reference-output stripping, abort handling, synthetic Responses event generation, final-output construction, keepalive management, resource-limit continuation handling, reader assignment, and deferred-event buffering.
• 🔴 (14:06) pipeline.ts:9654 defines stripHiddenReferenceOutput; its filtering logic compares item.id with syntheticId.
• 🔴 (14:06) The continuation tracks completion with let completed = false; and serializes output through encoder.encode(output).
• 🔴 (14:06) Abort handling checks signal.aborted, invokes void onLateResult() for late results, and declares let rejectAbort: ((reason: unknown) => void) | undefined;.
• 🔴 (14:06) Result accounting computes resultBytes using Buffer.byteLength(result.resultText) and elsewhere references input.resultText.
• 🔴 (14:06) The Responses event-generation section explicitly emits the sequence output_item.added, content_part.added, and repeated output_text.delta events using formatResponsesEvent(...).
• 🔴 (14:06) Usage normalization checks ru.cacheCreationInputTokens != null.
• 🔴 (14:06) Final response assembly initializes const finalOutput: Array<Record<string, unknown>> = [];, iterates output state, and looks up raw items with state.rawItems.get(index).
• 🔴 (14:06) Response normalization later retrieves const raw = acc.rawItems.get(outputIndex); and filters normalized.content.
• 🔴 (14:06) Keepalive handling sets keepaliveTimer = null, uses resetKeepalive(), and treats stream closure/cancellation as already handled.
• 🔴 (14:06) Resource-limit continuation logic declares let resourceLimitedContinuationResponse: GatewayResponse | undefined; and can classify the condition as "principal_resource_limit".
• 🔴 (14:06) A code comment states that recall items are gateway-internal and must remain hidden on every exit path.
• 🔴 (14:06) Stream processing assigns activeReader = reader, scans deferredEvents in reverse from deferredEvents.length - 1, and accumulates buffered size with deferredBytes += chunk.byteLength.