M.V. Hutz
bcc0331149
Move the event emitter and lifecycle events from the engine into the reducer, making the reducer the single point of orchestration for reduction. This eliminates the engine package entirely. - Add events.go to pkg/reducer with Start, Step, and Stop events. - Extend Reducer interface to embed Emitter and add Expression() method. - Update NormalOrderReducer to embed BaseEmitter and emit lifecycle events. - Update all plugins to attach to Reducer instead of Engine. - Remove internal/engine package. - Add Off() method to BaseEmitter to complete Emitter interface. - Fix Emitter.On signature to use generic type E instead of string.
47 lines
943 B
Go
47 lines
943 B
Go
package emitter
|
|
|
|
import "git.maximhutz.com/max/lambda/pkg/set"
|
|
|
|
type Emitter[E comparable] interface {
|
|
On(E, func()) Listener[E]
|
|
Off(Listener[E])
|
|
Emit(E)
|
|
}
|
|
|
|
type BaseEmitter[E comparable] struct {
|
|
listeners map[E]*set.Set[Listener[E]]
|
|
}
|
|
|
|
func (e *BaseEmitter[E]) On(kind E, fn func()) Listener[E] {
|
|
if e.listeners[kind] == nil {
|
|
e.listeners[kind] = set.New[Listener[E]]()
|
|
}
|
|
|
|
listener := &BaseListener[E]{kind, fn}
|
|
e.listeners[kind].Add(listener)
|
|
return listener
|
|
}
|
|
|
|
func (e *BaseEmitter[E]) Off(listener Listener[E]) {
|
|
kind := listener.Kind()
|
|
if e.listeners[kind] != nil {
|
|
e.listeners[kind].Remove(listener)
|
|
}
|
|
}
|
|
|
|
func (e *BaseEmitter[E]) Emit(event E) {
|
|
if e.listeners[event] == nil {
|
|
e.listeners[event] = set.New[Listener[E]]()
|
|
}
|
|
|
|
for listener := range e.listeners[event].Items() {
|
|
listener.Run()
|
|
}
|
|
}
|
|
|
|
func New[E comparable]() *BaseEmitter[E] {
|
|
return &BaseEmitter[E]{
|
|
listeners: map[E]*set.Set[Listener[E]]{},
|
|
}
|
|
}
|