Package io.reactivex.rxjava3.core
Class Scheduler.Worker.PeriodicTask
java.lang.Object
io.reactivex.rxjava3.core.Scheduler.Worker.PeriodicTask
- All Implemented Interfaces:
SchedulerRunnableIntrospection
,Runnable
- Enclosing class:
Scheduler.Worker
final class Scheduler.Worker.PeriodicTask
extends Object
implements Runnable, SchedulerRunnableIntrospection
Holds state and logic to calculate when the next delayed invocation
of this task has to happen (accounting for clock drifts).
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) long
(package private) long
(package private) final long
(package private) final @NonNull SequentialDisposable
(package private) long
-
Constructor Summary
ConstructorsConstructorDescriptionPeriodicTask
(long firstStartInNanoseconds, @NonNull Runnable decoratedRun, long firstNowNanoseconds, @NonNull SequentialDisposable sd, long periodInNanoseconds) -
Method Summary
-
Field Details
-
decoratedRun
-
sd
-
periodInNanoseconds
final long periodInNanoseconds -
count
long count -
lastNowNanoseconds
long lastNowNanoseconds -
startInNanoseconds
long startInNanoseconds
-
-
Constructor Details
-
PeriodicTask
-
-
Method Details
-
run
public void run() -
getWrappedRunnable
Description copied from interface:SchedulerRunnableIntrospection
Returns the wrapped action.- Specified by:
getWrappedRunnable
in interfaceSchedulerRunnableIntrospection
- Returns:
- the wrapped action. Cannot be null.
-