code: func (s *gRPCBrokerServer) Recv() (*plugin.ConnInfo, error) {
  	select {
  	case <-s.quit:
  		return nil, errors.New("broker closed")
  	case i := <-s.recv:
  		return i, nil
  	}
  }
docs: // Recv is used by the GRPCBroker to pass connection information that has been
  // sent from the client from the stream to the broker.