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 Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionBufferedTimedReplay
(Flowable<T> parent, int bufferSize, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) -
Method Summary
-
Field Details
-
parent
-
bufferSize
final int bufferSize -
time
final long time -
unit
-
scheduler
-
eagerTruncate
final boolean eagerTruncate
-
-
Constructor Details
-
BufferedTimedReplay
-
-
Method Details