docs: @Override
    public void query(final Query query, final int chunkSize, final Consumer<QueryResult> onNext,
                      final Runnable onComplete) {
      query(query, chunkSize, (cancellable, queryResult) -> onNext.accept(queryResult), onComplete);
    }