Skip to content

Commit 1a8c9c2

Browse files
committed
stream: don't register listeners if ended
1 parent 885c644 commit 1a8c9c2

1 file changed

Lines changed: 4 additions & 0 deletions

File tree

lib/internal/streams/async_iterator.js

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -155,6 +155,10 @@ const createReadableStreamAsyncIterator = (stream) => {
155155
});
156156
iterator[kLastPromise] = null;
157157

158+
if (iterator[kEnded]) {
159+
return iterator;
160+
}
161+
158162
finished(stream, { writable: false }, (err) => {
159163
if (err && err.code !== 'ERR_STREAM_PREMATURE_CLOSE') {
160164
const reject = iterator[kLastReject];

0 commit comments

Comments
 (0)