NDJSON Stream
This is a library to provide TransformStream for NDJSON.
Usage
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);
}