Package io.reactivex.rxjava3.core
Class Scheduler.PeriodicDirectTask
- java.lang.Object
-
- io.reactivex.rxjava3.core.Scheduler.PeriodicDirectTask
-
- All Implemented Interfaces:
Disposable,SchedulerRunnableIntrospection,java.lang.Runnable
- Enclosing class:
- Scheduler
static final class Scheduler.PeriodicDirectTask extends java.lang.Object implements Disposable, java.lang.Runnable, SchedulerRunnableIntrospection
-
-
Constructor Summary
Constructors Constructor Description PeriodicDirectTask(@NonNull java.lang.Runnable run, @NonNull Scheduler.Worker worker)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voiddispose()Dispose the resource, the operation should be idempotent.java.lang.RunnablegetWrappedRunnable()Returns the wrapped action.booleanisDisposed()Returns true if this resource has been disposed.voidrun()
-
-
-
Field Detail
-
worker
@NonNull final @NonNull Scheduler.Worker worker
-
disposed
volatile boolean disposed
-
-
Constructor Detail
-
PeriodicDirectTask
PeriodicDirectTask(@NonNull @NonNull java.lang.Runnable run, @NonNull @NonNull Scheduler.Worker worker)
-
-
Method Detail
-
run
public void run()
- Specified by:
runin interfacejava.lang.Runnable
-
dispose
public void dispose()
Description copied from interface:DisposableDispose the resource, the operation should be idempotent.- Specified by:
disposein interfaceDisposable
-
isDisposed
public boolean isDisposed()
Description copied from interface:DisposableReturns true if this resource has been disposed.- Specified by:
isDisposedin interfaceDisposable- Returns:
- true if this resource has been disposed
-
getWrappedRunnable
public java.lang.Runnable getWrappedRunnable()
Description copied from interface:SchedulerRunnableIntrospectionReturns the wrapped action.- Specified by:
getWrappedRunnablein interfaceSchedulerRunnableIntrospection- Returns:
- the wrapped action. Cannot be null.
-
-