code: private void terminateSubscriptions(IoSession session, Subscription.CloseReason reason) {
          Multiset<String> heapsForThisClient;
          try {
              subTermLock.lock();
              heapsForThisClient = heapsByClient.remove(session);
          } finally {
              subTermLock.unlock();
          }
  
          if (heapsForThisClient != null) {
              for (String s : heapsForThisClient.keySet()) {
                  terminateSubscriptions(session, s, reason);
              }
          }
      }
docs: Terminates all subscriptions for a given client