deno.land / std@0.177.1 / streams / merge_readable_streams_test.ts

merge_readable_streams_test.ts
نووسراو ببینە
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
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
import { mergeReadableStreams } from "./merge_readable_streams.ts";import { assertEquals } from "../testing/asserts.ts";
Deno.test("[streams] mergeReadableStreams", async () => { const textStream = new ReadableStream<string>({ start(controller) { controller.enqueue("qwertzuiopasd"); controller.enqueue("mnbvcxylkjhgfds"); controller.enqueue("apoiuztrewq0987654321"); controller.close(); }, });
const textStream2 = new ReadableStream<string>({ start(controller) { controller.enqueue("mnbvcxylkjhgfds"); controller.enqueue("apoiuztrewq0987654321"); controller.enqueue("qwertzuiopasd"); controller.close(); }, });
const buf = []; for await (const s of mergeReadableStreams(textStream, textStream2)) { buf.push(s); }
assertEquals(buf.sort(), [ "apoiuztrewq0987654321", "apoiuztrewq0987654321", "mnbvcxylkjhgfds", "mnbvcxylkjhgfds", "qwertzuiopasd", "qwertzuiopasd", ]);});
std

Version Info

Tagged at
10 months ago