reactor

type Demultiplexer[T any] interface {
	io.Closer
	// 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 Service[T], workers int)
	// Unregister unregisters handlers
	Unregister(id string)
}

type DemuxOptions[T any] struct {
	// contains filtered or unexported fields
}

type Event[T any] struct {
	ID ID

	Data T
	Err  error
	// contains filtered or unexported fields
}

type EventHandler[T, C any] func(T, func(C, error))

type ID []byte

type ReactiveService[T, C any] interface {
	Select(Event[T]) bool
	Handle(Event[T], func(C, error))
}

type Reactor[E, C any] interface {
	io.Closer
	Start(pctx context.Context) error

	Enqueue(events ...E)
	EnqueueWait(context.Context, E) (C, error)

	AddHandler(string, ReactiveService[E, C], int)
	RemoveHandler(string)

	AddCallback(string, Service[Event[C]], int)
	RemoveCallback(string)
}

type Service[T any] interface {
	Select(T) bool
	Handle(T)
}