eventbus

Jul 26, 2024

Changes in this version

+ var ErrListenerNotFound = errors.New("[event_bus] listener not found")

+ type EmitOption func(*emitOptions)

+ func WithEmitAsync() EmitOption

+ func WithEmitSkipErrors() EmitOption

+ type Event struct

+ func NewEvent[T any]() *Event[T]

+ func (t *Event[T]) Emit(ctx context.Context, msg T, opts ...EmitOption) error

+ func (t *Event[T]) EmitAsync(ctx context.Context, msg T, opts ...EmitOption) error

+ func (t *Event[T]) Listeners() []*Listener[T]

+ func (t *Event[T]) ListenersCount() int

+ func (t *Event[T]) Off(listener *Listener[T]) error

+ func (t *Event[T]) OffAll()

+ func (t *Event[T]) On(handler Handler[T]) *Listener[T]

+ type Handler interface

+ Handle func(ctx context.Context, msg T) error

+ type HandlerFunc func(ctx context.Context, msg T) error

+ func (f HandlerFunc[T]) Handle(ctx context.Context, msg T) error

+ type Listener struct

+ func (l *Listener[T]) Off() error