code: func (s *serfQueries) stream() {
  	for {
  		select {
  		case e := <-s.inCh:
  			// Check if this is a query we should process
  			if q, ok := e.(*Query); ok && strings.HasPrefix(q.Name, InternalQueryPrefix) {
  				go s.handleQuery(q)
  
  			} else if s.outCh != nil {
  				s.outCh <- e
  			}
  
  		case <-s.shutdownCh:
  			return
  		}
  	}
  }
docs: // stream is a long running routine to ingest the event stream