Versions in this module Expand all Collapse all v1 v1.15.1 Jun 9, 2025 Changes in this version + type Bus interface + func New(enableWildcards bool) Bus + type BusPublisher interface + Publish func(topic string, args ...interface{}) + type BusSubscriber interface + Subscribe func(topic string, fn interface{}) error + SubscribeAsync func(topic string, fn interface{}, transactional bool) error + Unsubscribe func(topic string, handler interface{}) error + WaitAsync func() + type EventBus struct + func (bus *EventBus) Publish(topic string, args ...interface{}) + func (bus *EventBus) Subscribe(topic string, fn interface{}) error + func (bus *EventBus) SubscribeAsync(topic string, fn interface{}, transactional bool) error + func (bus *EventBus) Unsubscribe(topic string, handler interface{}) error + func (bus *EventBus) WaitAsync()
Go to main page