diff --git a/lib/internal/streams/readable.js b/lib/internal/streams/readable.js index d52986ee2ccecd..30032360b3da60 100644 --- a/lib/internal/streams/readable.js +++ b/lib/internal/streams/readable.js @@ -1334,7 +1334,7 @@ function endReadableNT(state, stream) { stream.emit('end'); if (stream.writable && stream.allowHalfOpen === false) { - process.nextTick(endWritableNT, state, stream); + process.nextTick(endWritableNT, stream); } else if (state.autoDestroy) { // In case of duplex streams we need a way to detect // if the writable side is ready for autoDestroy as well. @@ -1353,7 +1353,7 @@ function endReadableNT(state, stream) { } } -function endWritableNT(state, stream) { +function endWritableNT(stream) { const writable = stream.writable && !stream.writableEnded && !stream.destroyed; if (writable) {