Class ObservableInternalHelper.TimedReplayCallable<T>
java.lang.Object
io.reactivex.rxjava3.internal.operators.observable.ObservableInternalHelper.TimedReplayCallable<T>
- All Implemented Interfaces:
Supplier<ConnectableObservable<T>>
- Enclosing class:
ObservableInternalHelper
static final class ObservableInternalHelper.TimedReplayCallable<T>
extends Object
implements Supplier<ConnectableObservable<T>>
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) final boolean
(package private) final Observable
<T> (package private) final Scheduler
(package private) final long
(package private) final TimeUnit
-
Constructor Summary
ConstructorsConstructorDescriptionTimedReplayCallable
(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate) -
Method Summary
-
Field Details
-
parent
-
time
final long time -
unit
-
scheduler
-
eagerTruncate
final boolean eagerTruncate
-
-
Constructor Details
-
TimedReplayCallable
TimedReplayCallable(Observable<T> parent, long time, TimeUnit unit, Scheduler scheduler, boolean eagerTruncate)
-
-
Method Details