Class FlowableInternalHelper.ReplaySupplier<T>

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

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

  • Constructor Details

    • ReplaySupplier

      ReplaySupplier(Flowable<T> parent)
  • 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