code: func (n *Notifier) takeSubscription() *Subscription {
  	n.mu.Lock()
  	defer n.mu.Unlock()
  	n.callReturned = true
  	return n.sub
  }
docs: // takeSubscription returns the subscription (if one has been created). No subscription can
  // be created after this call.