Class FlowableInternalHelper.BufferedTimedReplay<T>

java.lang.Object
io.reactivex.rxjava3.internal.operators.flowable.FlowableInternalHelper.BufferedTimedReplay<T>
All Implemented Interfaces:
Supplier<ConnectableFlowable<T>>
Enclosing class:
FlowableInternalHelper

static final class FlowableInternalHelper.BufferedTimedReplay<T> extends Object implements Supplier<ConnectableFlowable<T>>
  • Field Details

    • parent

      final Flowable<T> parent
    • bufferSize

      final int bufferSize
    • time

      final long time
    • unit

      final TimeUnit unit
    • scheduler

      final Scheduler scheduler
    • eagerTruncate

      final boolean eagerTruncate
  • Constructor Details

    • BufferedTimedReplay

      BufferedTimedReplay(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
  • Method Details

    • get

      public ConnectableFlowable<T> get()
      Description copied from interface: Supplier
      Produces a value or throws an exception.
      Specified by:
      get in interface Supplier<T>
      Returns:
      the value produced