Package rx.internal.operators
Class OnSubscribeToObservableFuture
java.lang.Object
rx.internal.operators.OnSubscribeToObservableFuture
Converts a
Future
into an Observable
.
You can convert any object that supports the Future
interface into an Observable
that emits
the return value of the get
method of that object, by using this operator.
This is blocking so the Subscription
returned when calling
Observable.unsafeSubscribe(Observer)
does nothing.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static class
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> Observable.OnSubscribe
<T> toObservableFuture
(Future<? extends T> that) static <T> Observable.OnSubscribe
<T> toObservableFuture
(Future<? extends T> that, long time, TimeUnit unit)
-
Constructor Details
-
OnSubscribeToObservableFuture
private OnSubscribeToObservableFuture()
-
-
Method Details
-
toObservableFuture
-
toObservableFuture
public static <T> Observable.OnSubscribe<T> toObservableFuture(Future<? extends T> that, long time, TimeUnit unit)
-