code: func (r *Registry) NewClient(path string, namespace types.StreamName) (Client, error) {
  	parts := strings.SplitN(path, ":", 2)
  	value := ""
  	if len(parts) == 2 {
  		value = parts[1]
  	}
  
  	r.lock.Lock()
  	defer r.lock.Unlock()
  
  	if f, ok := r.protocols[parts[0]]; ok {
  		return f(value, namespace)
  	}
  	return nil, fmt.Errorf("streamclient: no protocol registered for [%s]", parts[0])
  }
docs: // NewClient invokes the protocol ClientFactory generator for the
  // supplied protocol/address string, returning the generated Client.