code: func (ed *Dispatcher) EventCh() (chan<- interface{}, error) {
  	state := ed.getState()
  	if state == dispatcherStateStarted {
  		return ed.eventch, nil
  	}
  	return nil, errors.Errorf("dispatcher not started - Current state [%d]", state)
  }
docs: // EventCh returns the channel to which events may be posted