Skip to content

Commit ba74fd8

Browse files
committed
stream: remove ambiguous code
PR-URL: nodejs#29664 Reviewed-By: Minwoo Jung <minwoo@nodesource.com> Reviewed-By: Matteo Collina <matteo.collina@gmail.com>
1 parent 4eebd39 commit ba74fd8

1 file changed

Lines changed: 2 additions & 4 deletions

File tree

lib/internal/streams/end-of-stream.js

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -69,15 +69,13 @@ function eos(stream, opts, callback) {
6969
};
7070

7171
const onfinish = () => {
72-
writable = false;
7372
writableFinished = true;
74-
if (!readable) callback.call(stream);
73+
if (!readable || readableEnded) callback.call(stream);
7574
};
7675

7776
const onend = () => {
78-
readable = false;
7977
readableEnded = true;
80-
if (!writable) callback.call(stream);
78+
if (!writable || writableFinished) callback.call(stream);
8179
};
8280

8381
const onclose = () => {

0 commit comments

Comments
 (0)