code: public void assertSubscriptions() {
          for (String channel : subscribers.keySet()) {
              try {
                  subscribers.put(channel, null);
                  subscribe(channel);
              } catch (Throwable e) {
                  break;
              }
          }
      }
docs: Reassert subscriptions.