Class InternalObservableUtils.ReplaySupplierTime<T>

java.lang.Object
rx.internal.util.InternalObservableUtils.ReplaySupplierTime<T>
All Implemented Interfaces:
Callable<ConnectableObservable<T>>, Func0<ConnectableObservable<T>>, Function
Enclosing class:
InternalObservableUtils

static final class InternalObservableUtils.ReplaySupplierTime<T> extends Object implements Func0<ConnectableObservable<T>>
  • Field Details

    • time

      private final long time
    • unit

      private final TimeUnit unit
    • scheduler

      private final Scheduler scheduler
    • bufferSize

      private final int bufferSize
    • source

      private final Observable<T> source
  • Constructor Details

  • Method Details