emitter

Documentation

Index

• Constants
• Variables
• type Emitter
  • func New(factory ...events.DispatcherFactory) *Emitter
  • func NewWithType(typ int) *Emitter
  • func (emitter Emitter) Events() map[string]events.Dispatcher
  • func (emitter Emitter) Fire(e interface{}, mode int, context ...param.Store) error
  • func (emitter Emitter) HasEvent(event string) bool
  • func (emitter Emitter) Off(event string) events.Emitter
  • func (emitter Emitter) On(event string, handlers ...events.Listener) events.Emitter

Constants

const (
	Async = iota
	Sync
	Cond
)

Variables

var (
	DefaultDispatcherFactory = dispatcher.BroadcastFactory
	DefaultAsyncEmitter      = New(dispatcher.ParallelBroadcastFactory)
	DefaultSyncEmitter       = New(dispatcher.BroadcastFactory)
	DefaultCondEmitter       = New(dispatcher.ConditionalParallelBroadcastFactory)
)

Types

type Emitter

type Emitter struct {
	sync.Mutex
	DispatcherFactory events.DispatcherFactory
	Dispatchers       map[string]events.Dispatcher
}

func New

func New(factory ...events.DispatcherFactory) *Emitter

func NewWithType

func NewWithType(typ int) *Emitter

func (Emitter) Events

func (emitter Emitter) Events() map[string]events.Dispatcher

func (Emitter) Fire

func (emitter Emitter) Fire(e interface{}, mode int, context ...param.Store) error

func (Emitter) HasEvent

func (emitter Emitter) HasEvent(event string) bool

func (Emitter) Off

func (emitter Emitter) Off(event string) events.Emitter

func (Emitter) On

func (emitter Emitter) On(event string, handlers ...events.Listener) events.Emitter