fix: Missing channel close in QueuedChannel

ProtonMail · Sep 8, 2022 · 12c698d · 12c698d
1 parent 7314769
commit 12c698d
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/queue/queued_channel.go b/internal/queue/queued_channel.go
@@ -17,6 +17,8 @@ func NewQueuedChannel[T any](channelBufferSize int, capacity int) *QueuedChannel
 	}
 
 	go func() {
+		defer close(queue.ch)
+
 		for {
 			item, ok := queue.queue.Pop()
 			if !ok {