Fix panic in Jobpool.Wait()

aserto-dev · Jan 6, 2025 · 46b6abf · 46b6abf
1 parent 6fd6e74
commit 46b6abf
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/jobpool/jobpool.go b/jobpool/jobpool.go
@@ -83,12 +83,10 @@ func (jp *JobPool[IN, OUT]) Start() {
 // Results are returned in the order that jobs were produced.
 func (jp *JobPool[IN, OUT]) Wait() []OUT {
 	close(jp.inbox)
-	go func() {
-		jp.wg.Wait()
-		close(jp.outbox)
-	}()
+	jp.wg.Wait()
+	close(jp.outbox)
 
-	results := make([]OUT, len(jp.inbox))
+	results := make([]OUT, len(jp.outbox))
 	for result := range jp.outbox {
 		results[result.index] = result.result
 	}