Documentation ¶
Index ¶
- type EventBus
- func (_m *EventBus) HasCallback(topic string) bool
- func (_m *EventBus) Publish(topic string, args ...interface{})
- func (_m *EventBus) Subscribe(topic string, fn interface{}) error
- func (_m *EventBus) SubscribeAsync(topic string, fn interface{}, transactional bool) error
- func (_m *EventBus) SubscribeOnce(topic string, fn interface{}) error
- func (_m *EventBus) SubscribeOnceAsync(topic string, fn interface{}) error
- func (_m *EventBus) Unsubscribe(topic string, handler interface{}) error
- func (_m *EventBus) WaitAsync()
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventBus ¶
func (*EventBus) HasCallback ¶
func (*EventBus) SubscribeAsync ¶
func (*EventBus) SubscribeOnce ¶
func (*EventBus) SubscribeOnceAsync ¶
func (*EventBus) Unsubscribe ¶
Click to show internal directories.
Click to hide internal directories.