docs: private Completable clear() {
          return Completable.fromAction(() -> count.set(0))
                  //xian connection's close method is reentrant
                  .andThen(getConnection().close())
                  .andThen(doClear());
      }