Class FlowableInternalHelper.BufferedReplaySupplier<T>

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

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

    • parent

      final Flowable<T> parent
    • bufferSize

      final int bufferSize
    • eagerTruncate

      final boolean eagerTruncate
  • Constructor Details

    • BufferedReplaySupplier

      BufferedReplaySupplier(Flowable<T> parent, int bufferSize, 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