dispatcher

Documentation

Index

• type Dispatcher
• type EventDispatcher
  • func NewDispatcher() *EventDispatcher
  • func (d *EventDispatcher) AddListener(e arievent.EventType, l Listener)
  • func (d *EventDispatcher) Dispatch(e *arievent.StasisEvent) *arievent.StasisEvent
  • func (d *EventDispatcher) ExecuteOnce(e *arievent.StasisEvent, l Listener) Listener
  • func (d *EventDispatcher) GetPool() *ants.Pool
  • func (d *EventDispatcher) HasListeners(e arievent.EventType) bool
  • func (d *EventDispatcher) RemoveAll(e arievent.EventType)
  • func (d *EventDispatcher) RemoveListener(e arievent.EventType, l Listener)
• type Listener

Types

type Dispatcher

type Dispatcher interface {
	Dispatch(e arievent.StasisEvent) arievent.StasisEvent

	AddListener(e arievent.EventType, l Listener)

	RemoveListener(e arievent.EventType, l Listener)

	RemoveAllListener(e arievent.EventType)

	HasListeners(e arievent.EventType) bool
}

type EventDispatcher

type EventDispatcher struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDispatcher

func NewDispatcher() *EventDispatcher

func (*EventDispatcher) AddListener

func (d *EventDispatcher) AddListener(e arievent.EventType, l Listener)

func (*EventDispatcher) Dispatch

func (d *EventDispatcher) Dispatch(e *arievent.StasisEvent) *arievent.StasisEvent

func (*EventDispatcher) ExecuteOnce

func (d *EventDispatcher) ExecuteOnce(e *arievent.StasisEvent, l Listener) Listener

func (*EventDispatcher) GetPool

func (d *EventDispatcher) GetPool() *ants.Pool

func (*EventDispatcher) HasListeners

func (d *EventDispatcher) HasListeners(e arievent.EventType) bool

func (*EventDispatcher) RemoveAll

func (d *EventDispatcher) RemoveAll(e arievent.EventType)

func (*EventDispatcher) RemoveListener

func (d *EventDispatcher) RemoveListener(e arievent.EventType, l Listener)

type Listener

type Listener func(*arievent.StasisEvent)

Listener type for defining functions as listeners