diff --git a/lib/internal/streams/end-of-stream.js b/lib/internal/streams/end-of-stream.js index 1753996a4f85de..38235fc7ec1530 100644 --- a/lib/internal/streams/end-of-stream.js +++ b/lib/internal/streams/end-of-stream.js @@ -35,7 +35,8 @@ function eos(stream, opts, callback) { if (!stream.writable) onfinish(); }; - var writableEnded = stream._writableState && stream._writableState.finished; + var writableEnded = stream.writableFinished || + (stream._writableState && stream._writableState.finished); const onfinish = () => { writable = false; writableEnded = true;