fixed bug in awaitAll

alob-mtc · Apr 27, 2023 · 5421a67 · 5421a67
1 parent a99c483
commit 5421a67
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/eventloop.go b/eventloop.go
@@ -94,6 +94,7 @@ func (e *eventLoop) Run() {
 
 func (e *eventLoop) awaitAll() {
 	init := true
+outer:
 	for {
 		n := len(e.promiseQueue)
 		if init && n == 0 {
@@ -107,7 +108,7 @@ func (e *eventLoop) awaitAll() {
 				<-p.done
 			}
 			if currentN := int(atomic.LoadInt64(&e.size)); i == 0 && !(currentN > n) {
-				break
+				break outer
 			}
 		}
 		// clean up memory (promise)