nodejs
diff --git a/‎lib/internal/webstreams/adapters.js‎
Lines changed: 2 additions & 2 deletions b/‎lib/internal/webstreams/adapters.js‎
Lines changed: 2 additions & 2 deletions
diff --git a/‎test/parallel/test-whatwg-webstreams-adapters-to-readablewritablepair.js‎
Lines changed: 25 additions & 0 deletions b/‎test/parallel/test-whatwg-webstreams-adapters-to-readablewritablepair.js‎
Lines changed: 25 additions & 0 deletions
@@ -215,7 +215,7 @@ function newWritableStreamFromStreamWritable(streamWritable, options = kEmptyObj
         closed.reject(error);
         closed = undefined;
       }
-      controller.error(error);
+      controller?.error(error);
       controller = undefined;
       return;
     }
@@ -225,7 +225,7 @@ function newWritableStreamFromStreamWritable(streamWritable, options = kEmptyObj
       closed = undefined;
       return;
     }
-    controller.error(new AbortError());
+    controller?.error(new AbortError());
     controller = undefined;
   });
 
 
@@ -10,6 +10,7 @@ const {
 } = require('internal/webstreams/adapters');
 
 const {
+  Duplex,
   PassThrough,
 } = require('stream');
 
@@ -254,3 +255,27 @@ const {
     code: 'ERR_INVALID_ARG_TYPE'
   });
 }
+
+{
+  const duplex = new Duplex({
+    allowHalfOpen: false,
+    read() {},
+    write(chunk, enc, cb) { cb(); },
+    final(cb) { setImmediate(cb); },
+  });
+
+  const {
+    readable,
+    writable,
+  } = newReadableWritablePairFromDuplex(duplex);
+
+  const reader = readable.getReader();
+  const writer = writable.getWriter();
+
+  duplex.push(null);
+
+  reader.read().then(common.mustCall(({ done }) => {
+    assert.strictEqual(done, true);
+    writer.close().then(common.mustCall());
+  }));
+}
Original file line number	Diff line number	Diff line change
`@@ -215,7 +215,7 @@ function newWritableStreamFromStreamWritable(streamWritable, options = kEmptyObj`
`215`	`215`	`closed.reject(error);`
`216`	`216`	`closed = undefined;`
`217`	`217`	`}`
`218`		`- controller.error(error);`
	`218`	`+ controller?.error(error);`
`219`	`219`	`controller = undefined;`
`220`	`220`	`return;`
`221`	`221`	`}`
`@@ -225,7 +225,7 @@ function newWritableStreamFromStreamWritable(streamWritable, options = kEmptyObj`
`225`	`225`	`closed = undefined;`
`226`	`226`	`return;`
`227`	`227`	`}`
`228`		`- controller.error(new AbortError());`
	`228`	`+ controller?.error(new AbortError());`
`229`	`229`	`controller = undefined;`
`230`	`230`	`});`
`231`	`231`