Versions in this module Expand all Collapse all v1 v1.1.0 Nov 7, 2026 v1.0.0 Nov 7, 2026 Changes in this version + func On[T any](b *Bus, name string, mode Mode, h Handler[T]) + func Publish[T any](ctx context.Context, b *Bus, event T) error + type Bus struct + func New() *Bus + func (b *Bus) OnShutdown(ctx context.Context) error + func (b *Bus) Subscribers() map[string][]string + func (b *Bus) Wait() + type Handler func(ctx context.Context, event T) error + type Mode int + const Async + const Sync
Go to main page