reactor

type Handler[T any] func(T)

type Reactor[T any] interface {
	// Start starts the event loop
	Start(context.Context) error
	// Enqueue adds a new event to the event queue
	Enqueue(T)
	// Register registers handlers. It accepts the event selector, amount of goroutine workers
	// that will be used to process events, and the handlers that will be called.
	Register(id string, s Selector[T], workers int, handlers ...Handler[T])
	// Unregister unregisters handlers
	Unregister(id string)
}

type Selector[T any] func(T) bool