eventemitter

type BlockingEventEmitter[T any] struct {
	EventEmitter[T]
}

type EventEmitter[T any] struct {
	DefaultCapacity int // default capacity for channels, can be set to avoid blocking
	// contains filtered or unexported fields
}

type Receiver[T any] interface {
	Subscribe() chan T
	Unsubscribe(ch chan T)
}