code: public static <R> OnSubscribe<R> fromCallable(Callable<? extends R> callable) {
          return new InvokeAsync<R>(callable);
      }
docs: Subscriber function that invokes the callable and returns its value or
  propagates its checked exception.