refactor: use a single call to WaitGroup.Add in Publish

mdawar · Aug 13, 2024 · e393050 · e393050
1 parent d206c63
commit e393050
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/broker.go b/broker.go
@@ -152,8 +152,8 @@ func (b *Broker[T, P]) Publish(ctx context.Context, topic T, payload P) error {
 
 	var wg sync.WaitGroup
 
+	wg.Add(len(b.subs[topic]))
 	for _, sub := range b.subs[topic] {
-		wg.Add(1)
 		go func() {
 			defer wg.Done()