code: func (m *Memberlist) streamListen() {
  	for {
  		select {
  		case conn := <-m.transport.StreamCh():
  			go m.handleConn(conn)
  
  		case <-m.shutdownCh:
  			return
  		}
  	}
  }
docs: // streamListen is a long running goroutine that pulls incoming streams from the
  // transport and hands them off for processing.