code: func (s *gRPCBrokerClientImpl) Send(i *plugin.ConnInfo) error {
  	ch := make(chan error)
  	defer close(ch)
  
  	select {
  	case <-s.quit:
  		return errors.New("broker closed")
  	case s.send <- &sendErr{
  		i:  i,
  		ch: ch,
  	}:
  	}
  
  	return <-ch
  }
docs: // Send is used by the GRPCBroker to pass connection information into the stream
  // to the plugin.