nodejs
diff --git a/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
+8-1Lines changed: 8 additions & 1 deletion b/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
+8-1Lines changed: 8 additions & 1 deletion
diff --git a/Collapse file
‎test/parallel/test-webstreams-compression-bad-chunks.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-webstreams-compression-bad-chunks.js
+18Lines changed: 18 additions & 0 deletions b/Collapse file
‎test/parallel/test-webstreams-compression-bad-chunks.js‎
Copy file name to clipboardExpand all lines: test/parallel/test-webstreams-compression-bad-chunks.js
+18Lines changed: 18 additions & 0 deletions
diff --git a/Collapse file
‎test/wpt/status/compression.json‎
Copy file name to clipboardExpand all lines: test/wpt/status/compression.json
-8Lines changed: 0 additions & 8 deletions b/Collapse file
‎test/wpt/status/compression.json‎
Copy file name to clipboardExpand all lines: test/wpt/status/compression.json
-8Lines changed: 0 additions & 8 deletions
@@ -120,7 +120,14 @@ function handleKnownInternalErrors(cause) {
     case cause?.code === 'ERR_STREAM_PREMATURE_CLOSE': {
       return new AbortError(undefined, { cause });
     }
-    case ZLIB_FAILURES.has(cause?.code): {
+    case ZLIB_FAILURES.has(cause?.code):
+    // Brotli decoder error codes are formatted as 'ERR_' +
+    // BrotliDecoderErrorString(), where the latter returns strings like
+    // '_ERROR_FORMAT_...', '_ERROR_ALLOC_...', '_ERROR_UNREACHABLE', etc.
+    // The resulting JS error codes all start with 'ERR__ERROR_'.
+    // Falls through
+    case cause?.code != null &&
+      StringPrototypeStartsWith(cause.code, 'ERR__ERROR_'): {
       // eslint-disable-next-line no-restricted-syntax
       const error = new TypeError(undefined, { cause });
       error.code = cause.code;
 
@@ -55,3 +55,21 @@ for (const format of ['deflate', 'deflate-raw', 'gzip', 'brotli']) {
     });
   }
 }
+
+// Verify that decompression errors (e.g. corrupt data) are surfaced as
+// TypeError, not plain Error, per the Compression Streams spec.
+for (const format of ['deflate', 'deflate-raw', 'gzip', 'brotli']) {
+  test(`DecompressionStream surfaces corrupt data as TypeError for ${format}`, async () => {
+    const ds = new DecompressionStream(format);
+    const writer = ds.writable.getWriter();
+    const reader = ds.readable.getReader();
+
+    const corruptData = new Uint8Array([0, 1, 2, 3, 4, 5]);
+
+    writer.write(corruptData).catch(() => {});
+    reader.read().catch(() => {});
+
+    await assert.rejects(writer.close(), { name: 'TypeError' });
+    await assert.rejects(reader.closed, { name: 'TypeError' });
+  });
+}
@@ -1,12 +1,4 @@
 {
-  "decompression-bad-chunks.any.js": {
-    "fail": {
-      "expected": [
-        "chunk of type invalid deflate bytes should error the stream for brotli",
-        "chunk of type invalid gzip bytes should error the stream for brotli"
-      ]
-    }
-  },
   "compression-with-detach.window.js": {
     "requires": ["crypto"]
   },