eventemitter

May 14, 2021

Changes in this version

type Option

+ func WithIdleLoopExitingDuration(d time.Duration) Option

+ func WithPanicHandler(handler PanicHandler) Option

+ type PanicHandler func(event string, r interface{})

Mar 10, 2021

Changes in this version

+ var DefaultQueueSize = 128

Nov 26, 2020

Changes in this version

+ type AysncResult interface

+ Wait func()

+ WaitCtx func(ctx context.Context) error

+ func NewAysncResultImpl(wg *sync.WaitGroup) AysncResult

+ type AysncResultImpl struct

+ func (s *AysncResultImpl) Wait()

+ func (s *AysncResultImpl) WaitCtx(ctx context.Context) error

Nov 18, 2020

Changes in this version

+ type Decoder interface

+ Decode func(data []byte, result interface{}) error

+ type EventEmitter struct

+ func (e *EventEmitter) AddListener(evt string, listener interface{}) IEventEmitter

+ func (e *EventEmitter) Emit(evt string, args ...interface{}) bool

+ func (e *EventEmitter) Len() int

+ func (e *EventEmitter) ListenerCount(evt string) int

+ func (e *EventEmitter) Off(evt string, listener interface{}) IEventEmitter

+ func (e *EventEmitter) On(evt string, listener interface{}) IEventEmitter

+ func (e *EventEmitter) Once(evt string, listener interface{}) IEventEmitter

+ func (e *EventEmitter) RemoveAllListeners(evt string) IEventEmitter

+ func (e *EventEmitter) RemoveListener(evt string, listener interface{}) IEventEmitter

+ func (e *EventEmitter) SafeEmit(evt string, args ...interface{}) bool

+ type IEventEmitter interface

+ AddListener func(evt string, listener interface{}) IEventEmitter

+ Emit func(evt string, argv ...interface{}) bool

+ ListenerCount func(evt string) int

+ Off func(evt string, listener interface{}) IEventEmitter

+ On func(evt string, listener interface{}) IEventEmitter

+ Once func(evt string, listener interface{}) IEventEmitter

+ RemoveAllListeners func(evt string) IEventEmitter

+ RemoveListener func(evt string, listener interface{}) IEventEmitter

+ SafeEmit func(evt string, argv ...interface{}) bool

+ func NewEventEmitter(options ...Option) IEventEmitter

+ type JsonDecoder struct

+ func (JsonDecoder) Decode(data []byte, result interface{}) error

+ type Logger interface

+ Error func(format string, v ...interface{})

+ Warn func(format string, v ...interface{})

+ type Option func(*EventEmitter)

+ func WithDecoder(decoder Decoder) Option

+ func WithLogger(logger Logger) Option

+ func WithMaxListeners(num int) Option

+ func WithQueueSize(queueSize int) Option