event

type Broadcaster interface {
	RegisterListener(listener *Listener)
	RemoveListener(listener *Listener)
	RemoveAllListeners()
	BroadcastEvent(ctx context.Context, event Event)
}

type Event interface {
	EventSource() any

	Time() time.Time
}

type Listener struct {
	// contains filtered or unexported fields
}

type ListenerFunc[E Event] interface {
	~func(ctx context.Context, event E)
}

type ListenerRegistry interface {
	RegisterListener(listener *Listener)
	Listeners() []*Listener
}

type Publisher interface {
	PublishEvent(ctx context.Context, event Event)
}