@Override
  protected ReactorReader<T> newReader(Query query) {
    return new ReactorReader<>(query, session);
  }
Reader returning <a href="https://projectreactor.io">Reactor</a> types
criteria/reactor/src/org/immutables/criteria/reactor/ReactorReader.java