feat: return event data as interface when publish

dtomasi · Sep 4, 2021 · 2e41ea8 · 2e41ea8
1 parent b8902f4
commit 2e41ea8
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/event_bus.go b/event_bus.go
@@ -130,7 +130,7 @@ func (eb *EventBus) PublishAsync(topic string, data interface{}) {
 
 // Publish data to a topic and wait for all subscribers to finish
 // This function creates a waitGroup internally. All subscribers must call Done() function on Event.
-func (eb *EventBus) Publish(topic string, data interface{}) {
+func (eb *EventBus) Publish(topic string, data interface{}) interface{} {
 	wg := sync.WaitGroup{}
 	channels := eb.getSubscribingChannels(topic)
 	wg.Add(len(channels))
@@ -142,6 +142,8 @@ func (eb *EventBus) Publish(topic string, data interface{}) {
 			wg:    &wg,
 		})
 	wg.Wait()
+
+	return data
 }
 
 // Subscribe to a topic passing a EventChannel.