nodejs
diff --git a/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
+4-6Lines changed: 4 additions & 6 deletions b/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
+4-6Lines changed: 4 additions & 6 deletions
diff --git a/Collapse file
‎test/parallel/test-webstreams-duplex-fromweb-writev-unhandled-rejection.js‎
Copy file name to clipboard
+55Lines changed: 55 additions & 0 deletions b/Collapse file
‎test/parallel/test-webstreams-duplex-fromweb-writev-unhandled-rejection.js‎
Copy file name to clipboard
+55Lines changed: 55 additions & 0 deletions
@@ -314,9 +314,8 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
 
     writev(chunks, callback) {
       function done(error) {
-        error = error.filter((e) => e);
         try {
-          callback(error.length === 0 ? undefined : error);
+          callback(error);
         } catch (error) {
           // In a next tick because this is happening within
           // a promise context, and if there are any errors
@@ -334,7 +333,7 @@ function newStreamWritableFromWritableStream(writableStream, options = kEmptyObj
             SafePromiseAll(
               chunks,
               (data) => writer.write(data.chunk)),
-            done,
+            () => done(),
             done);
         },
         done);
@@ -787,9 +786,8 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
 
     writev(chunks, callback) {
       function done(error) {
-        error = error.filter((e) => e);
         try {
-          callback(error.length === 0 ? undefined : error);
+          callback(error);
         } catch (error) {
           // In a next tick because this is happening within
           // a promise context, and if there are any errors
@@ -807,7 +805,7 @@ function newStreamDuplexFromReadableWritablePair(pair = kEmptyObject, options =
             SafePromiseAll(
               chunks,
               (data) => writer.write(data.chunk)),
-            done,
+            () => done(),
             done);
         },
         done);
 
@@ -0,0 +1,55 @@
+'use strict';
+
+// Regression test for https://github.com/nodejs/node/issues/62199
+//
+// When Duplex.fromWeb is corked, writes are batched into _writev. If destroy()
+// is called in the same microtask (after uncork()), writer.ready rejects with a
+// non-array value. The done() callback inside _writev unconditionally called
+// error.filter(), which throws TypeError on non-arrays. This TypeError became
+// an unhandled rejection that crashed the process.
+//
+// The same bug exists in newStreamWritableFromWritableStream (Writable.fromWeb).
+
+const common = require('../common');
+const { Duplex, Writable } = require('stream');
+const { TransformStream, WritableStream } = require('stream/web');
+
+// Exact reproduction from the issue report (davidje13).
+// Before the fix: process crashes with unhandled TypeError.
+// After the fix: stream closes cleanly with no unhandled rejection.
+{
+  const output = Duplex.fromWeb(new TransformStream());
+
+  output.on('close', common.mustCall());
+
+  output.cork();
+  output.write('test');
+  output.write('test');
+  output.uncork();
+  output.destroy();
+}
+
+// Same bug in Writable.fromWeb (newStreamWritableFromWritableStream).
+{
+  const writable = Writable.fromWeb(new WritableStream());
+
+  writable.on('close', common.mustCall());
+
+  writable.cork();
+  writable.write('test');
+  writable.write('test');
+  writable.uncork();
+  writable.destroy();
+}
+
+// Regression: normal cork/uncork/_writev success path must still work.
+// Verifies that () => done() correctly signals success via callback().
+{
+  const writable = Writable.fromWeb(new WritableStream({ write() {} }));
+
+  writable.cork();
+  writable.write('foo');
+  writable.write('bar');
+  writable.uncork();
+  writable.end(common.mustCall());
+}