Package rx.internal.operators
Class OnSubscribeToObservableFuture.ToObservableFuture<T>
java.lang.Object
rx.internal.operators.OnSubscribeToObservableFuture.ToObservableFuture<T>
- All Implemented Interfaces:
Action
,Action1<Subscriber<? super T>>
,Function
,Observable.OnSubscribe<T>
- Enclosing class:
OnSubscribeToObservableFuture
static class OnSubscribeToObservableFuture.ToObservableFuture<T>
extends Object
implements Observable.OnSubscribe<T>
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionToObservableFuture
(Future<? extends T> that) ToObservableFuture
(Future<? extends T> that, long time, TimeUnit unit) -
Method Summary