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