Package io.reactivex.rxjava3.core

Class Scheduler.Worker.PeriodicTask

java.lang.Object

io.reactivex.rxjava3.core.Scheduler.Worker.PeriodicTask

All Implemented Interfaces:

SchedulerRunnableIntrospection, java.lang.Runnable

Enclosing class:

Scheduler.Worker

final class Scheduler.Worker.PeriodicTask
extends java.lang.Object
implements java.lang.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

Fields

Modifier and Type	Field	Description
(package private) long	count
(package private) @NonNull java.lang.Runnable	decoratedRun
(package private) long	lastNowNanoseconds
(package private) long	periodInNanoseconds
(package private) @NonNull SequentialDisposable	sd
(package private) long	startInNanoseconds

Constructor Summary

Constructors

Constructor	Description
PeriodicTask(long firstStartInNanoseconds, @NonNull java.lang.Runnable decoratedRun, long firstNowNanoseconds, @NonNull SequentialDisposable sd, long periodInNanoseconds)

Method Summary

Modifier and Type	Method	Description
java.lang.Runnable	getWrappedRunnable()	Returns the wrapped action.
void	run()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

decoratedRun

@NonNull
final @NonNull java.lang.Runnable decoratedRun

sd

@NonNull
final @NonNull SequentialDisposable sd

periodInNanoseconds

final long periodInNanoseconds

count

long count

lastNowNanoseconds

long lastNowNanoseconds

startInNanoseconds

long startInNanoseconds

Constructor Detail

PeriodicTask

PeriodicTask(long firstStartInNanoseconds,
             @NonNull
             @NonNull java.lang.Runnable decoratedRun,
             long firstNowNanoseconds,
             @NonNull
             @NonNull SequentialDisposable sd,
             long periodInNanoseconds)

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

getWrappedRunnable

public java.lang.Runnable getWrappedRunnable()

Description copied from interface: SchedulerRunnableIntrospection

Returns the wrapped action.

Specified by:

getWrappedRunnable in interface SchedulerRunnableIntrospection

Returns:

the wrapped action. Cannot be null.