Function streamResponse

nodejs/src/copilotRequestHandler.ts:698–726

(response: Response, exchange: CopilotRequestExchange)

}

async function streamResponse(response: Response, exchange: CopilotRequestExchange): Promise<void> {
    await exchange.startResponse({
        status: response.status,
        statusText: response.statusText || undefined,
        headers: headersToMultiMap(response.headers),
    });

    const body = response.body;
    if (!body) {
        await exchange.endResponse();
        return;
    }

    const reader = body.getReader();
    try {
        for (;;) {
            const { value, done } = await reader.read();
            if (done) {
                break;
            }
            if (value && value.byteLength > 0) {
                await exchange.writeResponse(value);
            }
        }
        await exchange.endResponse();
    } finally {
        reader.releaseLock();
    }
}

function headersToMultiMap(headers: Headers): LlmInferenceHeaders {
    const out: Record<string, string[]> = {};