Function testStream

src/WebWritableStream.spec.ts:104–143

(
    file: string,
    options?: ParserOptions,
)

}

async function testStream(
    file: string,
    options?: ParserOptions,
): Promise<void> {
    const filePath = new URL(`__fixtures__/Documents/${file}`, import.meta.url);

    const [streamHandler, eventsPromise] = getPromiseEventCollector();

    const fileContents = await fs.readFile(filePath);

    // Pipe file contents through a ReadableStream into the WebWritableStream
    const readable = new ReadableStream<Uint8Array>({
        start(controller) {
            controller.enqueue(new Uint8Array(fileContents));
            controller.close();
        },
    });

    await readable.pipeTo(new WebWritableStream(streamHandler, options));

    const events = await eventsPromise;

    expect(events).toMatchSnapshot();

    // Verify single-pass produces identical results
    const [singlePassHandler, singlePassPromise] = getPromiseEventCollector();

    const singlePassReadable = new ReadableStream<string>({
        start(controller) {
            controller.enqueue(fileContents.toString());
            controller.close();
        },
    });

    await singlePassReadable.pipeTo(
        new WebWritableStream(singlePassHandler, options),
    );

    expect(await singlePassPromise).toStrictEqual(events);
}