fixup! fixup! fix(ext/web): Prevent (De-)CompressionStream resource l…

…eak on stream cancellation

cli/tests/unit/streams_test.ts

@@ -1,5 +1,5 @@
 // Copyright 2018-2023 the Deno authors. All rights reserved. MIT license.
-import { assertEquals, fail } from "./test_util.ts";
+import { assertEquals, assertRejects, fail } from "./test_util.ts";
 
 const {
   core,
@@ -500,3 +500,28 @@ Deno.test(async function decompressionStreamReadableMayBeCancelled() {
     new DecompressionStream("deflate-raw").readable.getReader().cancel(),
   ]);
 });
+
+Deno.test(async function decompressionStreamValidGzipDoesNotThrow() {
+  const cs = new CompressionStream("gzip");
+  const ds = new DecompressionStream("gzip");
+  cs.readable.pipeThrough(ds);
+  const writer = cs.writable.getWriter();
+  await writer.write(new Uint8Array([1]));
+  writer.releaseLock();
+  await cs.writable.close();
+  let result = new Uint8Array();
+  for await (const chunk of ds.readable.values()) {
+    result = new Uint8Array([...result, ...chunk]);
+  }
+  assertEquals(result, new Uint8Array([1]));
+});
+
+Deno.test(async function decompressionStreamInvalidGzipStillReported() {
+  await assertRejects(
+    async () => {
+      await new DecompressionStream("gzip").writable.close();
+    },
+    TypeError,
+    "corrupt gzip stream does not have a matching checksum",
+  );
+});