code: func (r *serviceRegistry) subscription(service, name string) *callback {
  	r.mu.Lock()
  	defer r.mu.Unlock()
  	return r.services[service].subscriptions[name]
  }
docs: // subscription returns a subscription callback in the given service.