code: func (h *handler) cancelAllRequests(err error, inflightReq *requestOp) {
  	didClose := make(map[*requestOp]bool)
  	if inflightReq != nil {
  		didClose[inflightReq] = true
  	}
  
  	for id, op := range h.respWait {
  		// Remove the op so that later calls will not close op.resp again.
  		delete(h.respWait, id)
  
  		if !didClose[op] {
  			op.err = err
  			close(op.resp)
  			didClose[op] = true
  		}
  	}
  	for id, sub := range h.clientSubs {
  		delete(h.clientSubs, id)
  		sub.quitWithError(err, false)
  	}
  }
docs: // cancelAllRequests unblocks and removes pending requests and active subscriptions.