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
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
import { assertEquals } from "../testing/asserts.ts";import { readableStreamFromReader } from "./readable_stream_from_reader.ts";import { Buffer } from "../io/buffer.ts";import { concat } from "../bytes/concat.ts";import { copy } from "../bytes/copy.ts";import type { Closer, Reader } from "../types.d.ts";
class MockReaderCloser implements Reader, Closer {  chunks: Uint8Array[] = [];  closeCall = 0;
  read(p: Uint8Array): Promise<number | null> {    if (this.closeCall) {      throw new Error("already closed");    }    if (p.length === 0) {      return Promise.resolve(0);    }    const chunk = this.chunks.shift();    if (chunk) {      const copied = copy(chunk, p);      if (copied < chunk.length) {        this.chunks.unshift(chunk.subarray(copied));      }      return Promise.resolve(copied);    }    return Promise.resolve(null);  }
  close() {    this.closeCall++;  }}
Deno.test("[streams] readableStreamFromReader()", async function () {  const encoder = new TextEncoder();  const reader = new Buffer(encoder.encode("hello deno land"));  const stream = readableStreamFromReader(reader);  const actual: Uint8Array[] = [];  for await (const read of stream) {    actual.push(read);  }  const decoder = new TextDecoder();  assertEquals(decoder.decode(concat(...actual)), "hello deno land");});
Deno.test({  name: "[streams] readableStreamFromReader() auto closes closer",  async fn() {},});
Deno.test("[streams] readableStreamFromReader() - calls close", async function () {  const encoder = new TextEncoder();  const reader = new MockReaderCloser();  reader.chunks = [    encoder.encode("hello "),    encoder.encode("deno "),    encoder.encode("land"),  ];  const stream = readableStreamFromReader(reader);  const actual: Uint8Array[] = [];  for await (const read of stream) {    actual.push(read);  }  const decoder = new TextDecoder();  assertEquals(decoder.decode(concat(...actual)), "hello deno land");  assertEquals(reader.closeCall, 1);});
Deno.test("[streams] readableStreamFromReader() - doesn't call close with autoClose false", async function () {  const encoder = new TextEncoder();  const reader = new MockReaderCloser();  reader.chunks = [    encoder.encode("hello "),    encoder.encode("deno "),    encoder.encode("land"),  ];  const stream = readableStreamFromReader(reader, { autoClose: false });  const actual: Uint8Array[] = [];  for await (const read of stream) {    actual.push(read);  }  const decoder = new TextDecoder();  assertEquals(decoder.decode(concat(...actual)), "hello deno land");  assertEquals(reader.closeCall, 0);});
Deno.test("[streams] readableStreamFromReader() - chunkSize", async function () {  const encoder = new TextEncoder();  const reader = new MockReaderCloser();  reader.chunks = [    encoder.encode("hello "),    encoder.encode("deno "),    encoder.encode("land"),  ];  const stream = readableStreamFromReader(reader, { chunkSize: 2 });  const actual: Uint8Array[] = [];  for await (const read of stream) {    actual.push(read);  }  const decoder = new TextDecoder();  assertEquals(actual.length, 8);  assertEquals(decoder.decode(concat(...actual)), "hello deno land");  assertEquals(reader.closeCall, 1);});