Class FlowableInternalHelper.TimedReplay<T>

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

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

    • parent

      private final Flowable<T> parent
    • time

      private final long time
    • unit

      private final TimeUnit unit
    • scheduler

      private final Scheduler scheduler
    • eagerTruncate

      final boolean eagerTruncate
  • Constructor Details

  • 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