Skip to content

Commit 2629acb

Browse files
committed
events: don't call resume after close
1 parent b470ba0 commit 2629acb

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

lib/events.js

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1071,7 +1071,7 @@ function on(emitter, event, options = kEmptyObject) {
10711071
const value = unconsumedEvents.shift();
10721072
size--;
10731073
if (paused && size < lowWatermark) {
1074-
emitter.resume();
1074+
emitter.resume(); // Can not be finished yet
10751075
paused = false;
10761076
}
10771077
return PromiseResolve(createIterResult(value, false));
@@ -1188,6 +1188,7 @@ function on(emitter, event, options = kEmptyObject) {
11881188
abortListenerDisposable?.[SymbolDispose]();
11891189
removeAll();
11901190
finished = true;
1191+
paused = false;
11911192
const doneResult = createIterResult(undefined, true);
11921193
while (!unconsumedPromises.isEmpty()) {
11931194
unconsumedPromises.shift().resolve(doneResult);

0 commit comments

Comments
 (0)