Forwards one stage of a stream without letting it close the outer stream.
Drops the RESP_DONE and STREAM_END instructions, so several executors can stream into one response and only the last one finishes it.
RESP_DONE
STREAM_END
Chunks to forward.
The chunks, minus any terminal instructions.
for await (const chunk of streamStage(ctx.invokeStream(draft, request))) yield chunk;yield delta.end(); Copy
for await (const chunk of streamStage(ctx.invokeStream(draft, request))) yield chunk;yield delta.end();
Forwards one stage of a stream without letting it close the outer stream.
Drops the
RESP_DONEandSTREAM_ENDinstructions, so several executors can stream into one response and only the last one finishes it.