deno.land / std@0.224.0 / streams / byte_slice_stream_test.ts

byte_slice_stream_test.ts
View Documentation
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
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
import { assertEquals, assertThrows } from "../assert/mod.ts";import { ByteSliceStream } from "./byte_slice_stream.ts";
Deno.test("ByteSliceStream", async function () { function createStream(start = 0, end = Infinity) { return ReadableStream.from([ new Uint8Array([0, 1]), new Uint8Array([2, 3]), ]).pipeThrough(new ByteSliceStream(start, end)); }
let chunks = await Array.fromAsync(createStream(0, 3)); assertEquals(chunks, [ new Uint8Array([0, 1]), new Uint8Array([2, 3]), ]);
chunks = await Array.fromAsync(createStream(0, 1)); assertEquals(chunks, [ new Uint8Array([0, 1]), ]);
chunks = await Array.fromAsync(createStream(0, 2)); assertEquals(chunks, [ new Uint8Array([0, 1]), new Uint8Array([2]), ]);
chunks = await Array.fromAsync(createStream(0, 3)); assertEquals(chunks, [ new Uint8Array([0, 1]), new Uint8Array([2, 3]), ]);
chunks = await Array.fromAsync(createStream(1, 3)); assertEquals(chunks, [ new Uint8Array([1]), new Uint8Array([2, 3]), ]);
chunks = await Array.fromAsync(createStream(2, 3)); assertEquals(chunks, [ new Uint8Array([2, 3]), ]);
chunks = await Array.fromAsync(createStream(0, 10)); assertEquals(chunks, [ new Uint8Array([0, 1]), new Uint8Array([2, 3]), ]);
assertThrows(() => createStream(-1, Infinity));});
std

Version Info

Tagged at
6 months ago