ConcatenatedJsonParseStream
import { ConcatenatedJsonParseStream } from "jsr:@ende/json";class
class ConcatenatedJsonParseStream implements TransformStream<string, JsonValue>Stream to parse Concatenated JSON.
Example: Usage
import { ConcatenatedJsonParseStream } from "@ende/json/concatenated-json-parse-stream";
import { assertEquals } from "@ende/assert";
const stream = ReadableStream.from([
`{"foo":"bar"}`,
`{"baz":100}`,
]).pipeThrough(new ConcatenatedJsonParseStream());
assertEquals(await Array.fromAsync(stream), [
{ foo: "bar" },
{ baz: 100 },
]);Constructors
constructor
new ConcatenatedJsonParseStream()Constructs a new instance.
Properties
writable
readonly writable: WritableStream<string>A writable stream of byte data.
Example: Usage
import { ConcatenatedJsonParseStream } from "@ende/json/concatenated-json-parse-stream";
import { assertEquals } from "@ende/assert";
const stream = ReadableStream.from([
`{"foo":"bar"}`,
`{"baz":100}`,
]).pipeThrough(new ConcatenatedJsonParseStream());
assertEquals(await Array.fromAsync(stream), [
{ foo: "bar" },
{ baz: 100 },
]);readable
readonly readable: ReadableStream<JsonValue>A readable stream of byte data.
Example: Usage
import { ConcatenatedJsonParseStream } from "@ende/json/concatenated-json-parse-stream";
import { assertEquals } from "@ende/assert";
const stream = ReadableStream.from([
`{"foo":"bar"}`,
`{"baz":100}`,
]).pipeThrough(new ConcatenatedJsonParseStream());
assertEquals(await Array.fromAsync(stream), [
{ foo: "bar" },
{ baz: 100 },
]);