@Override
  public Offset<T> limit(long limit) {
    return newReader(query.withLimit(limit));
  }
Fetch available results in async fashion
criteria/reactor/src/org/immutables/criteria/reactor/ReactorReader.java