diff --git a/lib/internal/streams/duplexify.js b/lib/internal/streams/duplexify.js index beaf942b4b1288..b6374c0d1339ae 100644 --- a/lib/internal/streams/duplexify.js +++ b/lib/internal/streams/duplexify.js @@ -63,23 +63,23 @@ module.exports = function duplexify(body, name) { } if (isReadableNodeStream(body)) { - return _duplexify({ readable: body }); + return _duplexify({ __proto__: null, readable: body }); } if (isWritableNodeStream(body)) { - return _duplexify({ writable: body }); + return _duplexify({ __proto__: null, writable: body }); } if (isNodeStream(body)) { - return _duplexify({ writable: false, readable: false }); + return _duplexify({ __proto__: null, writable: false, readable: false }); } if (isReadableStream(body)) { - return _duplexify({ readable: Readable.fromWeb(body) }); + return _duplexify({ __proto__: null, readable: Readable.fromWeb(body) }); } if (isWritableStream(body)) { - return _duplexify({ writable: Writable.fromWeb(body) }); + return _duplexify({ __proto__: null, writable: Writable.fromWeb(body) }); } if (typeof body === 'function') { @@ -173,7 +173,7 @@ module.exports = function duplexify(body, name) { duplexify(body.writable) : undefined; - return _duplexify({ readable, writable }); + return _duplexify({ __proto__: null, readable, writable }); } const then = body?.then; @@ -231,12 +231,12 @@ function fromAsyncGen(fn) { write(chunk, encoding, cb) { const _resolve = resolve; resolve = null; - _resolve({ chunk, done: false, cb }); + _resolve({ __proto__: null, chunk, done: false, cb }); }, final(cb) { const _resolve = resolve; resolve = null; - _resolve({ done: true, cb }); + _resolve({ __proto__: null, done: true, cb }); }, destroy(err, cb) { ac.abort();