eventbus

type Bus interface {
	Controller
	Slotter
	Emitter
}

type Controller interface {
	HasSlot(topic string) bool
	WaitAsync()
}

type Emitter interface {
	Emit(topic string, args ...interface{})
}

type GenericBus[T any] interface {
	// Slot register event handler
	Slot(topic string, handler func(T))
	// SlotAsync 注册异步事件处理器
	SlotAsync(topic string, handler func(T), transactional bool)
	// SlotOnce register once event handler
	SlotOnce(topic string, handler func(T))
	// SlotOnceAsync register once asynchronous event handler
	SlotOnceAsync(topic string, handler func(T))
	// Emit emit event
	Emit(topic string, data T)
	// Unslot remove event handler
	Unslot(topic string, handler func(T)) bool
	// HasSlot check if there is a handler
	HasSlot(topic string) bool
	// WaitAsync wait for asynchronous processing to complete
	WaitAsync()
}

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

type Slotter interface {
	Slot(topic string, fn interface{}) error
	SlotAsync(topic string, fn interface{}, transactional bool) error
	SlotOnce(topic string, fn interface{}) error
	SlotOnceAsync(topic string, fn interface{}) error
	Unslot(topic string, handler interface{}) error
}

type StandardBus interface {
	// Slot register event handler
	Slot(topic string, handler interface{}) error
	// SlotAsync register asynchronous event handler
	SlotAsync(topic string, handler interface{}, transactional bool) error
	// SlotOnce register once event handler
	SlotOnce(topic string, handler interface{}) error
	// SlotOnceAsync register once asynchronous event handler
	SlotOnceAsync(topic string, handler interface{}) error
	// Emit emit event
	Emit(topic string, args ...interface{})
	// Unslot remove event handler
	Unslot(topic string, handler interface{}) error
	// HasSlot check if there is a handler
	HasSlot(topic string) bool
	// WaitAsync wait for asynchronous processing to complete
	WaitAsync()
}

type StandardEventBus struct {
	// contains filtered or unexported fields
}