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 Details

    • that

      final Future<? extends T> that
    • time

      private final long time
    • unit

      private final TimeUnit unit
  • Constructor Details

    • ToObservableFuture

      public ToObservableFuture(Future<? extends T> that)
    • ToObservableFuture

      public ToObservableFuture(Future<? extends T> that, long time, TimeUnit unit)
  • Method Details