diff options
Diffstat (limited to 'ext/node/polyfills/_stream.mjs')
| -rw-r--r-- | ext/node/polyfills/_stream.mjs | 3 |
1 files changed, 1 insertions, 2 deletions
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({ |