@Override
  public void dispose() {
    try {
      cqQuery.close();
    } catch (CqException e) {
      logger.error("Failed to close {} [{}]", cqQuery.getName(), cqQuery.getQueryString(), e);
    }
  }
Disposable (rxjava interface) wrapper for {@link CqQuery}
criteria/geode/src/org/immutables/criteria/geode/CqDisposable.java