events

May 20, 2022

Changes in this version

type Listener

+ func WithID(l Listener, id string) Listener

May 20, 2022

Changes in this version

+ func StreamWithID(id string) *stream

+ type ID interface

+ ID func() string

+ type Streamer interface

+ Chan func() <-chan Event

Feb 14, 2022

Changes in this version

type Emitter

+ func (emitter *Emitter) FireByName(name string, options ...EventOption) error

+ func (emitter *Emitter) FireByNameWithMap(name string, data Map) error

type Emitterer

+ FireByName func(name string, options ...EventOption) error

+ FireByNameWithMap func(name string, data Map) error

Feb 14, 2022

Changes in this version

type Emitter

+ func (emitter *Emitter) EventNames() []string

type Emitterer

+ EventNames func() []string

Feb 14, 2022

Changes in this version

+ var Default = NewEmitter()

+ func Broadcast(event Event, handlers map[Listener]struct{}) (err error)

+ func ParallelBroadcast(event Event, handlers map[Listener]struct{}) error

+ func ParallelBroadcastWithReturning(event Event, handlers map[Listener]struct{}) error

+ type DispatchStrategy func(Event, map[Listener]struct{}) error

type Dispatcher

+ func NewDispatcher(strategy DispatchStrategy) *Dispatcher

+ func (dispatcher *Dispatcher) AddSubscriber(handler Listener)

+ func (dispatcher *Dispatcher) RemoveSubscriber(handler Listener)

+ type Dispatcherer interface

+ AddSubscriber func(handler Listener)

+ AddSubscribers func([]Listener)

+ Dispatch func(Event) error

+ RemoveSubscriber func(handler Listener)

type Emitter

+ func NewEmitter(options ...EmitterOption) *Emitter

+ func (emitter *Emitter) AddEventListener(handler Listener, events ...string)

+ func (emitter *Emitter) AddEventListeners(event string, handlers ...Listener)

+ func (emitter *Emitter) RemoveEventListener(handler Listener)

+ func (emitter *Emitter) RemoveEventListeners(event string)

+ type EmitterOption struct

+ func WithDefaultStrategy(strategy DispatchStrategy) EmitterOption

+ func WithEventStategy(event string, strategy DispatchStrategy) EmitterOption

+ type Emitterer interface

+ AddEventListener func(handler Listener, events ...string)

+ Fire func(interface{}) error

+ HasEvent func(string) bool

+ Off func(string) Emitterer

+ On func(string, ...Listener) Emitterer

+ RemoveEventListener func(handler Listener)

+ type EventOption struct

+ func WithContext(context Map) EventOption

+ type Map = param.Store

+ type PeriodicEmitter struct

+ func NewTicker(emitter *Emitter) *PeriodicEmitter

+ func (emitter *PeriodicEmitter) RegisterEvent(event string, period interface{}, handlers ...Listener)

+ func (emitter *PeriodicEmitter) RemoveEvent(event string)

+ func (emitter *PeriodicEmitter) Stop()

Sep 13, 2019

Changes in this version

+ const ModeAsync

+ const ModeSync

+ const ModeWait

+ func ToMap(key string, value interface{}, args ...interface{}) param.Store

+ type Callback func(Event) error

+ func (callback Callback) Handle(event Event) error

+ type Dispatcher interface

+ AddSubscribers func(...Listener)

+ Dispatch func(Event) error

+ type DispatcherFactory func() Dispatcher

+ type Emitter interface

+ Events func() map[string]Dispatcher

+ Fire func(interface{}, int, ...param.Store) error

+ HasEvent func(string) bool

+ Off func(string) Emitter

+ On func(string, ...Listener) Emitter

+ type Event struct

+ Context param.Store

+ Key string

+ func New(name string) Event

+ func (event *Event) Abort() *Event

+ func (event *Event) Aborted() bool

+ func (event *Event) String() string

+ type Listener interface

+ Handle func(Event) error

+ type Stream chan Event

+ func (stream Stream) Handle(event Event) error