Function readAllSSEEvents

test/server/sse.test.ts:57–78

(response: Response)

};

async function readAllSSEEvents(response: Response): Promise<string[]> {
    const reader = response.body?.getReader();
    if (!reader) throw new Error('No readable stream');

    const events: string[] = [];
    const decoder = new TextDecoder();

    try {
        while (true) {
            const { done, value } = await reader.read();
            if (done) break;

            if (value) {
                events.push(decoder.decode(value));
            }
        }
    } finally {
        reader.releaseLock();
    }

    return events;
}

/**
 * Helper to send JSON-RPC request