code: func (r *Registry) RegisterServerFunc(stream string, f func(*Peer, string, bool) (Server, error)) {
  	r.serverMu.Lock()
  	defer r.serverMu.Unlock()
  
  	r.serverFuncs[stream] = f
  }
docs: // RegisterServer registers an outgoing streamer constructor