Package rx.internal.operators
Class OnSubscribeToObservableFuture
- java.lang.Object
-
- rx.internal.operators.OnSubscribeToObservableFuture
-
public final class OnSubscribeToObservableFuture extends java.lang.Object
Converts aFuture
into anObservable
.You can convert any object that supports the
Future
interface into anObservable
that emits the return value of theget
method of that object, by using this operator.This is blocking so the
Subscription
returned when callingObservable.unsafeSubscribe(Observer)
does nothing.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
OnSubscribeToObservableFuture.ToObservableFuture<T>
-
Constructor Summary
Constructors Modifier Constructor Description private
OnSubscribeToObservableFuture()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <T> Observable.OnSubscribe<T>
toObservableFuture(java.util.concurrent.Future<? extends T> that)
static <T> Observable.OnSubscribe<T>
toObservableFuture(java.util.concurrent.Future<? extends T> that, long time, java.util.concurrent.TimeUnit unit)
-
-
-
Method Detail
-
toObservableFuture
public static <T> Observable.OnSubscribe<T> toObservableFuture(java.util.concurrent.Future<? extends T> that)
-
toObservableFuture
public static <T> Observable.OnSubscribe<T> toObservableFuture(java.util.concurrent.Future<? extends T> that, long time, java.util.concurrent.TimeUnit unit)
-
-