@Override
    public LimitOffset<T1, T2, T3> distinct() {
      return new Mapper3<>(query.withDistinct(true), session);
    }
Default implementation for various rxjava mappers and their utilities
criteria/reactor/src/org/immutables/criteria/reactor/ReactorMappers.java