From 4ed9278bf4c47670d9dda61a0d6e07e82cba3992 Mon Sep 17 00:00:00 2001 From: Yoshiya Hinosawa Date: Tue, 28 Nov 2023 12:14:57 +0900 Subject: fix(ext/node): fix duplexify compatibility (#21346) --- ext/node/polyfills/_stream.mjs | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) (limited to 'ext') diff --git a/ext/node/polyfills/_stream.mjs b/ext/node/polyfills/_stream.mjs index 23df11ab3..d6db3020b 100644 --- a/ext/node/polyfills/_stream.mjs +++ b/ext/node/polyfills/_stream.mjs @@ -4474,6 +4474,7 @@ var require_duplexify = __commonJS({ readable: false, }); } + if (typeof body === "function") { const { value, write, final, destroy } = fromAsyncGen(body); if (isIterable(value)) { @@ -4669,8 +4670,6 @@ var require_duplexify = __commonJS({ cb(err); } else if (err) { d.destroy(err); - } else if (!readable && !writable) { - d.destroy(); } } d = new Duplexify({ -- cgit v1.2.3