Converts a Future into a Single and awaits its outcome in a blocking fashion. The operator calls Future#get(), which is a blocking me
(@NonNull Future<? extends T> future)
| 1017 | * @see #fromCompletionStage(CompletionStage) |
| 1018 | */ |
| 1019 | @CheckReturnValue |
| 1020 | @SchedulerSupport(SchedulerSupport.NONE) |
| 1021 | @NonNull |
| 1022 | public static <@NonNull T> Single<T> fromFuture(@NonNull Future<? extends T> future) { |
| 1023 | return toSingle(Flowable.fromFuture(future)); |
| 1024 | } |
| 1025 | |
| 1026 | /** |
| 1027 | * Converts a {@link Future} into a {@code Single} and awaits its outcome, or timeout, in a blocking fashion. |