Package io.reactivex.rxjava3.core

Class Scheduler.PeriodicDirectTask

java.lang.Object

io.reactivex.rxjava3.core.Scheduler.PeriodicDirectTask

All Implemented Interfaces:

Disposable, SchedulerRunnableIntrospection, Runnable

Enclosing class:

Scheduler

static final class Scheduler.PeriodicDirectTask
extends Object
implements Disposable, Runnable, SchedulerRunnableIntrospection

Field Summary

Fields

Modifier and Type	Field	Description
(package private) boolean	disposed
(package private) final @NonNull Runnable	run
(package private) final @NonNull Scheduler.Worker	worker

Constructor Summary

Constructors

Constructor	Description
PeriodicDirectTask(@NonNull Runnable run, @NonNull Scheduler.Worker worker)

Method Summary

Modifier and Type	Method	Description
void	dispose()	Dispose the resource, the operation should be idempotent.
Runnable	getWrappedRunnable()	Returns the wrapped action.
boolean	isDisposed()	Returns true if this resource has been disposed.
void	run()

Methods inherited from class java.lang.Object

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

Field Details

run

@NonNull
final @NonNull Runnable run

worker

@NonNull
final @NonNull Scheduler.Worker worker

disposed

volatile boolean disposed

Constructor Details

PeriodicDirectTask

PeriodicDirectTask(@NonNull
 @NonNull Runnable run,
 @NonNull
 @NonNull Scheduler.Worker worker)

Method Details

run

public void run()

Specified by:

run in interface Runnable

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

isDisposed

public boolean isDisposed()

Description copied from interface: Disposable

Returns true if this resource has been disposed.

Specified by:

isDisposed in interface Disposable

Returns:

true if this resource has been disposed

getWrappedRunnable

public Runnable getWrappedRunnable()

Description copied from interface: SchedulerRunnableIntrospection

Returns the wrapped action.

Specified by:

getWrappedRunnable in interface SchedulerRunnableIntrospection

Returns:

the wrapped action. Cannot be null.