code: func (es *etcdEventStream) Next(stop chan struct{}) chan pkg.Event {
  	evchan := make(chan pkg.Event)
  	go func() {
  		for {
  			select {
  			case <-stop:
  				return
  			default:
  			}
  
  			res := watch(es.kAPI, path.Join(es.rootPrefix, jobPrefix), stop)
  			if ev, ok := parse(res, es.rootPrefix); ok {
  				evchan <- ev
  				return
  			}
  		}
  
  	}()
  
  	return evchan
  }
docs: // Next returns a channel which will emit an Event as soon as one of interest occurs