Fix data race on simplifiedEventBus.bus

Signed-off-by: Anton Litvinov <[email protected]>
mysteriumnetwork · Mar 21, 2024 · 1c6d7c3 · 1c6d7c3
1 parent fe72e46
commit 1c6d7c3
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/eventbus/event_bus.go b/eventbus/event_bus.go
@@ -103,9 +103,11 @@ func (b *simplifiedEventBus) Publish(topic string, data interface{}) {
 
 	b.mu.RLock()
 	ids := b.sub[topic]
+	idsCopy := make([]string, len(ids))
+	copy(idsCopy, ids)
 	b.mu.RUnlock()
 
-	for _, id := range ids {
+	for _, id := range idsCopy {
 		b.bus.Publish(topic+id, data)
 	}
 }