From cf960326c23de67cea2a5b500af6186b0739376e Mon Sep 17 00:00:00 2001 From: Robert Nagy Date: Mon, 26 Jul 2021 06:46:19 +0200 Subject: [PATCH] Update lib/internal/streams/duplexify.js Co-authored-by: Antoine du Hamel --- lib/internal/streams/duplexify.js | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/lib/internal/streams/duplexify.js b/lib/internal/streams/duplexify.js index 72d75b4773430a..0c6e74b9c70719 100644 --- 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,