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
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
// Copyright 2018-2022 the Deno authors. All rights reserved. MIT license.
import { TextLineStream } from "./text_line_stream.ts";import { assertEquals } from "../testing/asserts.ts";
Deno.test("[streams] TextLineStream", async () => {  const textStream = new ReadableStream({    start(controller) {      controller.enqueue("qwertzu");      controller.enqueue("iopasd\r\nmnbvc");      controller.enqueue("xylk\rjhgfds\napoiuzt\r");      controller.enqueue("qwr\r09ei\rqwrjiowqr\r");      controller.enqueue("\nrewq0987\n\n654321");      controller.enqueue("\nrewq0987\r\n\r\n654321\r");      controller.close();    },  });
  const lines = [];  for await (const chunk of textStream.pipeThrough(new TextLineStream())) {    lines.push(chunk);  }  assertEquals(lines, [    "qwertzuiopasd",    "mnbvcxylk\rjhgfds",    "apoiuzt\rqwr\r09ei\rqwrjiowqr",    "rewq0987",    "",    "654321",    "rewq0987",    "",    "654321\r",  ]);
  const textStream2 = new ReadableStream({    start(controller) {      controller.enqueue("rewq0987\r\n\r\n654321\n");      controller.close();    },  });
  const lines2 = [];  for await (const chunk of textStream2.pipeThrough(new TextLineStream())) {    lines2.push(chunk);  }  assertEquals(lines2, [    "rewq0987",    "",    "654321",    "",  ]);});
Deno.test("[streams] TextLineStream - allowCR", async () => {  const textStream = new ReadableStream({    start(controller) {      controller.enqueue("qwertzu");      controller.enqueue("iopasd\r\nmnbvc");      controller.enqueue("xylk\rjhgfds\napoiuzt\r");      controller.enqueue("qwr\r09ei\rqwrjiowqr\r");      controller.enqueue("\nrewq0987\n\n654321");      controller.enqueue("\nrewq0987\r\n\r\n654321\r");      controller.close();    },  });
  const lines = [];  for await (    const chunk of textStream.pipeThrough(new TextLineStream({ allowCR: true }))  ) {    lines.push(chunk);  }  assertEquals(lines, [    "qwertzuiopasd",    "mnbvcxylk",    "jhgfds",    "apoiuzt",    "qwr",    "09ei",    "qwrjiowqr",    "rewq0987",    "",    "654321",    "rewq0987",    "",    "654321",    "",  ]);
  const textStream2 = new ReadableStream({    start(controller) {      controller.enqueue("rewq0987\r\n\r\n654321\n");      controller.close();    },  });
  const lines2 = [];  for await (const chunk of textStream2.pipeThrough(new TextLineStream())) {    lines2.push(chunk);  }  assertEquals(lines2, [    "rewq0987",    "",    "654321",    "",  ]);});
Deno.test("[streams] TextLineStream - large chunks", async () => {  const textStream = new ReadableStream({    start(controller) {      controller.enqueue("\n".repeat(10000));      controller.enqueue("\n".repeat(10000));      controller.close();    },  });
  let lines = 0;  for await (const chunk of textStream.pipeThrough(new TextLineStream())) {    assertEquals(chunk, "");    lines++;  }  assertEquals(lines, 20001);});