bus

type Bus[EM Emittable, SU Subscriber[EM]] struct {
	// contains filtered or unexported fields
}

type Emittable interface {
	ID() uuid.UUID
	Topic() string
	Cancel()
	Canceled() bool
}

type Option func(*Options)

type Options struct {
	Demuxers     int
	ErrorBuilder func(error) Emittable
}

type PriorityQueue[P cmp.Ordered, V any] interface {
	Push(elem V, priority P)
	Pop() (V, bool)
	Peek() V
	Size() int
	Clear()
}

type Subscriber[EM Emittable] interface {
	ID() uuid.UUID
	Topic() string
	Handle(em EM) error
}