@Override
  public AsyncReader<T> findAll() {
    return new AsyncReader<>(Query.of(session.entityType()), session);
  }
Readable which uses {@link java.util.concurrent.CompletionStage}
criteria/common/src/org/immutables/criteria/repository/async/AsyncReadable.java