Function start

test/client/stream.test.ts:246–252

(controller)

  it('preserves event fields split across network chunks', async () => {
    const body = new ReadableStream<Uint8Array>({
      start(controller) {
        const encoder = new TextEncoder();
        controller.enqueue(encoder.encode('id: 7\nevent: mes'));
        controller.enqueue(encoder.encode('sage\ndata: hel'));
        controller.enqueue(encoder.encode('lo\n\n'));
        controller.close();
      },
    });

    const events = await collectEvents(new Response(body));