fixing issue with queue.Start()

nano-interactive · May 12, 2024 · aef9f9e · aef9f9e
1 parent 8d26755
commit aef9f9e
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/consumer/queue.go b/consumer/queue.go
@@ -42,5 +42,7 @@ func (c *Consumer[T]) Start(base context.Context) error {
 
 	defer conn.Close()
 
+	<-base.Done()
+
 	return nil
 }