Class InternalObservableUtils.ReplaySupplierBuffer<T>

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

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

    • source

      private final Observable<T> source
    • bufferSize

      private final int bufferSize
  • Constructor Details

    • ReplaySupplierBuffer

      private ReplaySupplierBuffer(Observable<T> source, int bufferSize)
  • Method Details