code: func (m *SubscriptionManager) cancelSubscription(sub *newSubscription) {
  	select {
  	case m.cancelSubscriptions <- &cancelSubscription{sub.id}:
  	case <-m.quit:
  	}
  }
docs: // cancelSubscription sends a request to the subscription handler to cancel an
  // existing subscription.