nodejs
diff --git a/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
+8-2Lines changed: 8 additions & 2 deletions b/Collapse file
‎lib/internal/webstreams/adapters.js‎
Copy file name to clipboardExpand all lines: lib/internal/webstreams/adapters.js
+8-2Lines changed: 8 additions & 2 deletions
diff --git a/Collapse file
‎test/parallel/test-stream-toWeb-allows-server-response.js‎
Copy file name to clipboard
+29Lines changed: 29 additions & 0 deletions b/Collapse file
‎test/parallel/test-stream-toWeb-allows-server-response.js‎
Copy file name to clipboard
+29Lines changed: 29 additions & 0 deletions
@@ -101,11 +101,17 @@ function newWritableStreamFromStreamWritable(streamWritable) {
   // here because it will return false if streamWritable is a Duplex
   // whose writable option is false. For a Duplex that is not writable,
   // we want it to pass this check but return a closed WritableStream.
-  if (typeof streamWritable?._writableState !== 'object') {
+  // We check if the given stream is a stream.Writable or http.OutgoingMessage
+  const checkIfWritableOrOutgoingMessage =
+    streamWritable &&
+    typeof streamWritable?.write === 'function' &&
+    typeof streamWritable?.on === 'function';
+  if (!checkIfWritableOrOutgoingMessage) {
     throw new ERR_INVALID_ARG_TYPE(
       'streamWritable',
       'stream.Writable',
-      streamWritable);
+      streamWritable
+    );
   }
 
   if (isDestroyed(streamWritable) || !isWritable(streamWritable)) {
 
@@ -0,0 +1,29 @@
+'use strict';
+const common = require('../common');
+const { Writable } = require('stream');
+
+const assert = require('assert');
+const http = require('http');
+
+// Check if Writable.toWeb works on the response object after creating a server.
+const server = http.createServer(
+  common.mustCall((req, res) => {
+    const webStreamResponse = Writable.toWeb(res);
+    assert.strictEqual(webStreamResponse instanceof WritableStream, true);
+    res.end();
+  })
+);
+
+server.listen(
+  0,
+  common.mustCall(() => {
+    http.get(
+      {
+        port: server.address().port,
+      },
+      common.mustCall(() => {
+        server.close();
+      })
+    );
+  })
+);