@Override
  public RxJavaFetcher<T> offset(long offset) {
    return newReader(query.withOffset(offset));
  }
Fetch available results in reactive fashion
criteria/rxjava2/src/org/immutables/criteria/repository/rxjava2/RxJavaReader.java