foster/denoland-deno
1
0
Fork 0
mirror of https://github.com/denoland/deno.git synced 2024-11-25 15:29:32 -05:00
Code Issues Packages 1 Wiki Activity

chore(ext/web): use a non-resource stream for textDecoderStreamCleansUpOnCancel (#21181)

Browse source 
Follow-up fix to #21074
This commit is contained in:
Matt Mastracci 2023-11-13 11:35:48 -07:00 committed by GitHub
parent 25950baed3
commit 65b9150f83
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
cli/tests/unit/text_encoding_test.ts
View file

@ -1,5 +1,10 @@
// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license. // Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
import { assert, assertEquals, assertThrows } from "./test_util.ts"; import {
assert,
assertEquals,
assertStrictEquals,
assertThrows,
} from "./test_util.ts";
Deno.test(function btoaSuccess() { Deno.test(function btoaSuccess() {
const text = "hello world"; const text = "hello world";
@ -323,9 +328,15 @@ Deno.test(function binaryEncode() {
Deno.test( Deno.test(
{ permissions: { read: true } }, { permissions: { read: true } },
async function textDecoderStreamCleansUpOnCancel() { async function textDecoderStreamCleansUpOnCancel() {
const filename = "cli/tests/testdata/assets/hello.txt"; let cancelled = false;
const file = await Deno.open(filename); const readable = new ReadableStream({
const readable = file.readable.pipeThrough(new TextDecoderStream()); start: (controller) => {
controller.enqueue(new Uint8Array(12));
},
cancel: () => {
cancelled = true;
},
}).pipeThrough(new TextDecoderStream());
const chunks = []; const chunks = [];
for await (const chunk of readable) { for await (const chunk of readable) {
chunks.push(chunk); chunks.push(chunk);
@ -334,5 +345,6 @@ Deno.test(
} }
assertEquals(chunks.length, 1); assertEquals(chunks.length, 1);
assertEquals(chunks[0].length, 12); assertEquals(chunks[0].length, 12);
assertStrictEquals(cancelled, true);
}, },
); );