Method Publish

pkg/events/basic/pubsub.go:83–96

Publish publishes an event, which will notify all matching subscriptions.

(evs ...events.Event)

// Publish publishes an event, which will notify all matching subscriptions.
func (e *PubSub) Publish(evs ...events.Event) {
	e.mu.RLock()
	subscriptions := e.subscriptions
	e.mu.RUnlock()
	for _, evt := range evs {
		trace.WithRegion(evt.Context(), "publish event", func() {
			for _, sub := range subscriptions {
				if sub.Match(evt) {
					sub.Notify(evt)
				}
			}
		})
	}
}