public static <X> Publisher<X> limit(Publisher<X> publisher, long count) {
    return Flowable.fromPublisher(publisher).limit(count);
  }
Get single result from publisher (blocking operation)
criteria/common/src/org/immutables/criteria/repository/Publishers.java