- java.lang.Object
-
- rx
.internal .operators .OnSubscribeToObservableFuture
- rx
-
public final class OnSubscribeToObservableFuture extends Object
Converts aFutureinto anObservable.
You can convert any object that supports the
Futureinterface into anObservablethat emits the return value of thegetmethod of that object, by using this operator.This is blocking so the
Subscriptionreturned when callingObservable.unsafeSubscribe(Observer)does nothing.
-
-
Method Summary
Methods
Modifier and Type Method and Description static <T> Observable.OnSubscribe <T> toObservableFuture(Future<? extends T> that) static <T> Observable.OnSubscribe <T> toObservableFuture(Future<? extends T> that, long time, TimeUnit unit)
-
-
-
Method Detail
toObservableFuture
public static <T> Observable
.OnSubscribe <T> toObservableFuture(Future <? extends T> that)
toObservableFuture
public static <T> Observable
.OnSubscribe <T> toObservableFuture(Future <? extends T> that, long time, TimeUnit unit)
-