code: func (r *Registry) RegisterClientFunc(stream string, f func(*Peer, string, bool) (Client, error)) {
  	r.clientMu.Lock()
  	defer r.clientMu.Unlock()
  
  	r.clientFuncs[stream] = f
  }
docs: // RegisterClient registers an incoming streamer constructor