1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
import assert from "assert";import { encode, decodeArrayStream } from "../src";
describe("decodeArrayStream", () => {  const generateSampleObject = () => {    return {      id: Math.random(),      name: "test",    };  };
  const createStream = async function* (object: any) {    for (const byte of encode(object)) {      yield [byte];    }  };
  it("decodes numbers array (array8)", async () => {    const object = [1, 2, 3, 4, 5];
    const result: Array<unknown> = [];
    for await (const item of decodeArrayStream(createStream(object))) {      result.push(item);    }
    assert.deepStrictEqual(object, result);  });
  it("decodes numbers of array (array16)", async () => {    const createStream = async function* () {      yield [0xdc, 0, 3];      yield encode(1);      yield encode(2);      yield encode(3);    };
    const result: Array<unknown> = [];
    for await (const item of decodeArrayStream(createStream())) {      result.push(item);    }
    assert.deepStrictEqual(result, [1, 2, 3]);  });
  it("decodes numbers of array (array32)", async () => {    const createStream = async function* () {      yield [0xdd, 0, 0, 0, 3];      yield encode(1);      yield encode(2);      yield encode(3);    };
    const result: Array<unknown> = [];
    for await (const item of decodeArrayStream(createStream())) {      result.push(item);    }
    assert.deepStrictEqual(result, [1, 2, 3]);  });
  it("decodes objects array", async () => {    const objectsArrays: Array<any> = [];
    for (let i = 0; i < 10; i++) {      objectsArrays.push(generateSampleObject());    }
    const result: Array<unknown> = [];
    for await (const item of decodeArrayStream(createStream(objectsArrays))) {      result.push(item);    }
    assert.deepStrictEqual(objectsArrays, result);  });
  it("fails for non array input", async () => {    const object = "demo";
    await assert.rejects(async () => {      const result: Array<unknown> = [];
      for await (const item of decodeArrayStream(createStream(object))) {        result.push(item);      }    }, /.*Unrecognized array type byte:.*/i);  });});