Versions in this module Expand all Collapse all v0 v0.4.1 Apr 29, 2026 v0.4.0 Mar 26, 2026 Changes in this version + func Subscribe[T any](b *EventBus, handler HandlerFunc[T]) string + type EventBus struct + func NewEventBus(pool taskrunner.ThreadPool) *EventBus + func NewEventBusFromRunner(runner *taskrunner.SequencedTaskRunner) *EventBus + func (b *EventBus) Close() + func (b *EventBus) Publish(ctx context.Context, event any) + func (b *EventBus) Unsubscribe(id string) + func (b *EventBus) WaitIdle(ctx context.Context) error + type HandlerFunc func(ctx context.Context, event T)
Go to main page