deno.land / x / msgpack_javascript@v3.0.0-beta2 / test / decodeMultiStream.test.ts
12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061import assert from "assert";import { encode, decodeMultiStream } from "@msgpack/msgpack";
describe("decodeStream", () => { it("decodes stream", async () => { const items = [ "foo", 10, { name: "bar", }, [1, 2, 3], ];
const createStream = async function* (): AsyncGenerator<Uint8Array> { for (const item of items) { yield encode(item); } };
const result: Array<unknown> = [];
for await (const item of decodeMultiStream(createStream())) { result.push(item); }
assert.deepStrictEqual(result, items); });
it("decodes multiple objects in a single binary stream", async () => { const items = [ "foo", 10, { name: "bar", }, [1, 2, 3], ];
const encodedItems = items.map((item) => encode(item)); const encoded = new Uint8Array(encodedItems.reduce((p, c) => p + c.byteLength, 0)); let offset = 0; for (const encodedItem of encodedItems) { encoded.set(encodedItem, offset); offset += encodedItem.byteLength; }
const createStream = async function* (): AsyncGenerator<Uint8Array> { yield encoded; };
const result: Array<unknown> = [];
for await (const item of decodeMultiStream(createStream())) { result.push(item); }
assert.deepStrictEqual(result, items); });});
Version Info