Class ConcatenatedJsonParseStream

Stream to parse Concatenated JSON.

import { ConcatenatedJsonParseStream } from "@std/json/concatenated-json-parse-stream";
import { assertEquals } from "@std/assert";

const stream = ReadableStream.from([
`{"foo":"bar"}`,
`{"baz":100}`,
]).pipeThrough(new ConcatenatedJsonParseStream());

assertEquals(await Array.fromAsync(stream), [
{ foo: "bar" },
{ baz: 100 },
]);
Implements

Constructors

Properties

Constructors

Properties

readable: ReadableStream<JsonValue>

A readable stream of byte data.

import { ConcatenatedJsonParseStream } from "@std/json/concatenated-json-parse-stream";
import { assertEquals } from "@std/assert";

const stream = ReadableStream.from([
`{"foo":"bar"}`,
`{"baz":100}`,
]).pipeThrough(new ConcatenatedJsonParseStream());

assertEquals(await Array.fromAsync(stream), [
{ foo: "bar" },
{ baz: 100 },
]);
writable: WritableStream<string>

A writable stream of byte data.

import { ConcatenatedJsonParseStream } from "@std/json/concatenated-json-parse-stream";
import { assertEquals } from "@std/assert";

const stream = ReadableStream.from([
`{"foo":"bar"}`,
`{"baz":100}`,
]).pipeThrough(new ConcatenatedJsonParseStream());

assertEquals(await Array.fromAsync(stream), [
{ foo: "bar" },
{ baz: 100 },
]);