public static <X> List<X> blockingListGet(Publisher<X> publisher) {
    return Flowable.fromPublisher(publisher).toList().blockingGet();
  }
Blocking get as list of results
criteria/common/src/org/immutables/criteria/repository/Publishers.java