event

type ApplicationEvent interface {
	EventSource() any
	EventTime() time.Time
}

type AsyncTypedPublisher[E ApplicationEvent] interface {
	PublishEventAsync(ctx context.Context, event E) error
}

type Listener interface {
	OnEvent(ctx context.Context, event ApplicationEvent) error
	SupportsEvent(event ApplicationEvent) bool
}

type Multicaster interface {
	AddEventListener(listener Listener) error
	MulticastEvent(ctx context.Context, event ApplicationEvent) error
	MulticastEventAsync(ctx context.Context, event ApplicationEvent) error
	RemoveEventListener(listener Listener) error
	RemoveAllEventListeners()
}

type Publisher interface {
	PublishEvent(ctx context.Context, event ApplicationEvent) error
	PublishEventAsync(ctx context.Context, event ApplicationEvent) error
}

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

type TypedPublisher[E ApplicationEvent] interface {
	PublishEvent(ctx context.Context, event E) error
}