import { NdjsonStream } from "ndjson-stream/index";

async function processStream<T>(stream: ReadableStreamDefaultReader<T>): Promise<void> {
    while (true) {
        const { done, value } = await stream.read();
        if (done) {
            return;
        }

        console.log(value);
    }
}

async function main(): Promise<void> {
    const ndjsonStream = new NdjsonStream();

    const input = '{"abc": 123}\r\n\r\n{"def": 456}\n';
    const stream = new Blob([input]).stream();
    const chained = stream.pipeThrough(ndjsonStream).getReader();
    await processStream(chained);
}