docs: public static <T> Future<T> fromPublisher(final Publisher<T> pub, final Executor ex) {
          final ValueSubscriber<T> sub = ValueSubscriber.subscriber();
          pub.subscribe(sub);
          return sub.toFutureAsync(ex);
      }