Package io.reactivex.rxjava3.core

Class Scheduler.DisposeTask

java.lang.Object

io.reactivex.rxjava3.core.Scheduler.DisposeTask

All Implemented Interfaces:

Disposable, SchedulerRunnableIntrospection, Runnable

Enclosing class:

Scheduler

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

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final @NonNull Runnable	decoratedRun
(package private) @Nullable Thread	runner
(package private) final @NonNull Scheduler.Worker	w

Constructor Summary

Constructors

Constructor	Description
DisposeTask(@NonNull Runnable decoratedRun, @NonNull Scheduler.Worker w)

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

decoratedRun

@NonNull
final @NonNull Runnable decoratedRun

w

@NonNull
final @NonNull Scheduler.Worker w

runner

@Nullable
@Nullable Thread runner

Constructor Details

DisposeTask

DisposeTask(@NonNull
 @NonNull Runnable decoratedRun,
 @NonNull
 @NonNull Scheduler.Worker w)

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.