Update lib/internal/streams/duplexify.js

Co-authored-by: Antoine du Hamel <duhamelantoine1995@gmail.com>
nodejs · Jul 26, 2021 · cf96032 · cf96032
1 parent 7904fb0
commit cf96032
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/lib/internal/streams/duplexify.js b/lib/internal/streams/duplexify.js
@@ -66,18 +66,19 @@ module.exports = function duplexify(body, name) {
       });
     }
 
-    if (typeof value?.then === 'function') {
+    const { then } = value;
+    if (typeof then === 'function') {
       let d;
 
-      const promise = PromiseResolve(value)
-        .then((val) => {
+      const promise = FunctionPrototypeCall(then, value,
+        (val) => {
           if (val != null) {
             throw new ERR_INVALID_RETURN_VALUE('nully', 'body', val);
           }
-        })
-        .catch((err) => {
+        },
+        (err) => {
           destroyer(d, err);
-        });
+        }));
 
       return d = new Duplex({
         objectMode: true,