Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv class	ExecutorScheduler.DelayedDispose
pack-priv static class	ExecutorScheduler.DelayedRunnable
public static class	ExecutorScheduler.ExecutorWorker

Modifier and Type	Field and Description
pack-priv final Executor	executor
pack-priv static final Scheduler	HELPER
pack-priv final boolean	interruptibleWorker

Constructor Summary

Access	Constructor and Description
public	ExecutorScheduler(Executor executor, boolean interruptibleWorker)

Method Summary

Modifier and Type	Method and Description
public Scheduler.Worker	createWorker() Implements abstract io.reactivex.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions.
public Disposable	scheduleDirect(Runnable the task to execute run) Overrides io.reactivex.Scheduler.scheduleDirect. Schedules the given task on this Scheduler without any time delay.
public Disposable	scheduleDirect(Runnable the task to schedule run, final long the delay amount, non-positive values indicate non-delayed scheduling delay, final TimeUnit the unit of measure of the delay amount unit) Overrides io.reactivex.Scheduler.scheduleDirect. Schedules the execution of the given task with the given time delay.
public Disposable	schedulePeriodicallyDirect(Runnable the task to schedule run, long the initial delay amount, non-positive values indicate non-delayed scheduling initialDelay, long the period at which the task should be re-executed period, TimeUnit the unit of measure of the delay amount unit) Overrides io.reactivex.Scheduler.schedulePeriodicallyDirect. Schedules a periodic execution of the given task with the given initial time delay and repeat period.

Inherited from io.reactivex.Scheduler:: clockDriftTolerance now shutdown start when

executor	back to summary
pack-priv final Executor executor Annotations @NonNull

HELPER	back to summary
pack-priv static final Scheduler HELPER

interruptibleWorker	back to summary
pack-priv final boolean interruptibleWorker

Constructor Detail

ExecutorScheduler	back to summary
public ExecutorScheduler(Executor executor, boolean interruptibleWorker)

Method Detail

createWorker back to summary

createWorker	back to summary
public Scheduler.Worker createWorker() Implements abstract io.reactivex.Scheduler.createWorker. Doc from io.reactivex.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions. When work is completed, the `Worker` instance should be released by calling `Scheduler.Worker#dispose()` to avoid potential resource leaks in the underlying task-execution scheme. Work on a `Scheduler.Worker` is guaranteed to be sequential and non-overlapping. Returns:Scheduler.Worker a Worker representing a serial queue of actions to be executed Annotations @NonNull @Override

public Scheduler.Worker createWorker()

Implements abstract io.reactivex.Scheduler.createWorker.

Doc from io.reactivex.Scheduler.createWorker.

Retrieves or creates a new Scheduler.Worker that represents sequential execution of actions.

When work is completed, the Worker instance should be released by calling Scheduler.Worker#dispose() to avoid potential resource leaks in the underlying task-execution scheme.

Work on a Scheduler.Worker is guaranteed to be sequential and non-overlapping.

Returns:Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations

@NonNull
@Override

scheduleDirect	back to summary
public Disposable scheduleDirect(Runnable run) Overrides io.reactivex.Scheduler.scheduleDirect. Doc from io.reactivex.Scheduler.scheduleDirect. Schedules the given task on this Scheduler without any time delay. This method is safe to be called from multiple threads but there are no ordering or non-overlapping guarantees between tasks. Parameters run:Runnable the task to execute Returns:Disposable the Disposable instance that let's one cancel this particular task. Annotations @NonNull @Override

scheduleDirect

back to summary

public Disposable scheduleDirect(Runnable run)

Overrides io.reactivex.Scheduler.scheduleDirect.

Doc from io.reactivex.Scheduler.scheduleDirect.

Schedules the given task on this Scheduler without any time delay.

This method is safe to be called from multiple threads but there are no ordering or non-overlapping guarantees between tasks.

Parameters

run:Runnable: the task to execute

Returns:Disposable

the Disposable instance that let's one cancel this particular task.

Annotations

@NonNull
@Override

scheduleDirect	back to summary
public Disposable scheduleDirect(Runnable run, final long delay, final TimeUnit unit) Overrides io.reactivex.Scheduler.scheduleDirect. Doc from io.reactivex.Scheduler.scheduleDirect. Schedules the execution of the given task with the given time delay. This method is safe to be called from multiple threads but there are no ordering guarantees between tasks. Parameters run:Runnable the task to schedule delay:long the delay amount, non-positive values indicate non-delayed scheduling unit:TimeUnit the unit of measure of the delay amount Returns:Disposable the Disposable that let's one cancel this particular delayed task. Annotations @NonNull @Override

scheduleDirect

back to summary

public Disposable scheduleDirect(Runnable run, final long delay, final TimeUnit unit)

Overrides io.reactivex.Scheduler.scheduleDirect.

Doc from io.reactivex.Scheduler.scheduleDirect.

Schedules the execution of the given task with the given time delay.

This method is safe to be called from multiple threads but there are no ordering guarantees between tasks.

Parameters

run:Runnable: the task to schedule
delay:long: the delay amount, non-positive values indicate non-delayed scheduling
unit:TimeUnit: the unit of measure of the delay amount

Returns:Disposable

the Disposable that let's one cancel this particular delayed task.

Annotations

@NonNull
@Override

schedulePeriodicallyDirect back to summary

schedulePeriodicallyDirect	back to summary
public Disposable schedulePeriodicallyDirect(Runnable run, long initialDelay, long period, TimeUnit unit) Overrides io.reactivex.Scheduler.schedulePeriodicallyDirect. Doc from io.reactivex.Scheduler.schedulePeriodicallyDirect. Schedules a periodic execution of the given task with the given initial time delay and repeat period. This method is safe to be called from multiple threads but there are no ordering guarantees between tasks. The periodic execution is at a fixed rate, that is, the first execution will be after the `initialDelay`, the second after `initialDelay + period`, the third after `initialDelay + 2 * period`, and so on. Parameters run:Runnable the task to schedule initialDelay:long the initial delay amount, non-positive values indicate non-delayed scheduling period:long the period at which the task should be re-executed unit:TimeUnit the unit of measure of the delay amount Returns:Disposable the Disposable that let's one cancel this particular delayed task. Annotations @NonNull @Override

public Disposable schedulePeriodicallyDirect(Runnable run, long initialDelay, long period, TimeUnit unit)

Overrides io.reactivex.Scheduler.schedulePeriodicallyDirect.

Doc from io.reactivex.Scheduler.schedulePeriodicallyDirect.

Schedules a periodic execution of the given task with the given initial time delay and repeat period.

This method is safe to be called from multiple threads but there are no ordering guarantees between tasks.

The periodic execution is at a fixed rate, that is, the first execution will be after the initialDelay, the second after initialDelay + period, the third after initialDelay + 2 * period, and so on.

Parameters

run:Runnable: the task to schedule
initialDelay:long: the initial delay amount, non-positive values indicate non-delayed scheduling
period:long: the period at which the task should be re-executed
unit:TimeUnit: the unit of measure of the delay amount

Returns:Disposable

the Disposable that let's one cancel this particular delayed task.

Annotations

@NonNull
@Override

io.reactivex.internal.schedulers back to summary

pack-priv final Class ExecutorScheduler.DelayedDispose

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.internal.schedulers.ExecutorScheduler.DelayedDispose

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final ExecutorScheduler.DelayedRunnable	dr

Constructor Summary

Access	Constructor and Description
pack-priv	DelayedDispose(ExecutorScheduler.DelayedRunnable dr)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

dr	back to summary
private final ExecutorScheduler.DelayedRunnable dr

Constructor Detail

DelayedDispose	back to summary
pack-priv DelayedDispose(ExecutorScheduler.DelayedRunnable dr)

Method Detail

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.reactivex.internal.schedulers back to summary

pack-priv final Class ExecutorScheduler.DelayedRunnable

Class Inheritance

extends AtomicReference<Runnable>
implements Runnable, Disposable, SchedulerRunnableIntrospection

java.lang.Object
java.util.concurrent.atomic.AtomicReference
io.reactivex.internal.schedulers.ExecutorScheduler.DelayedRunnable

All Implemented Interfaces

io.reactivex.schedulers.SchedulerRunnableIntrospection, io.reactivex.disposables.Disposable, java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final SequentialDisposable	direct
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.
pack-priv final SequentialDisposable	timed

Constructor Summary

Access	Constructor and Description
pack-priv	DelayedRunnable(Runnable run)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public Runnable	getWrappedRunnable() Implements io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable. Returns the wrapped action.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Field Detail

direct	back to summary
pack-priv final SequentialDisposable direct

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

timed	back to summary
pack-priv final SequentialDisposable timed

Constructor Detail

DelayedRunnable	back to summary
pack-priv DelayedRunnable(Runnable run)

Method Detail

dispose	back to summary
public void dispose() Implements io.reactivex.disposables.Disposable.dispose. Doc from io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

getWrappedRunnable	back to summary
public Runnable getWrappedRunnable() Implements io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable. Doc from io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable. Returns the wrapped action. Returns:Runnable the wrapped action. Cannot be null. Annotations @Override

getWrappedRunnable

back to summary

public Runnable getWrappedRunnable()

Implements io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Doc from io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Returns the wrapped action.

Returns:Runnable

the wrapped action. Cannot be null.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Doc from io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.reactivex.internal.schedulers back to summary

public final Class ExecutorScheduler.ExecutorWorker

Class Inheritance

extends Worker
implements Runnable

java.lang.Object
io.reactivex.Scheduler.Worker
io.reactivex.internal.schedulers.ExecutorScheduler.ExecutorWorker

All Implemented Interfaces

java.lang.Runnable

Nested and Inner Type Summary

Modifier and Type	Class and Description
pack-priv static class	ExecutorScheduler.ExecutorWorker.BooleanRunnable
pack-priv static class	ExecutorScheduler.ExecutorWorker.InterruptibleRunnable Wrapper for a `Runnable` with additional logic for handling interruption on a shared thread, similar to how Java Executors do it.
pack-priv class	ExecutorScheduler.ExecutorWorker.SequentialDispose

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	disposed
pack-priv final Executor	executor
pack-priv final boolean	interruptibleWorker
pack-priv final MpscLinkedQueue<Runnable>	queue
pack-priv final CompositeDisposable	tasks
pack-priv final AtomicInteger	wip

Constructor Summary

Access	Constructor and Description
public	ExecutorWorker(Executor executor, boolean interruptibleWorker)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	run() Implements java.lang.Runnable.run. Runs this operation.
public Disposable	schedule(Runnable Runnable to schedule run) Overrides io.reactivex.Scheduler.Worker.schedule. Schedules a Runnable for execution without any time delay.
public Disposable	schedule(Runnable the Runnable to schedule run, long time to "wait" before executing the action; non-positive values indicate an non-delayed schedule delay, TimeUnit the time unit of `delayTime` unit) Implements abstract io.reactivex.Scheduler.Worker.schedule. Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

Inherited from io.reactivex.Scheduler.Worker:: now schedulePeriodically

Field Detail

disposed	back to summary
pack-priv volatile boolean disposed

executor	back to summary
pack-priv final Executor executor

interruptibleWorker	back to summary
pack-priv final boolean interruptibleWorker

queue	back to summary
pack-priv final MpscLinkedQueue<Runnable> queue

tasks	back to summary
pack-priv final CompositeDisposable tasks

wip	back to summary
pack-priv final AtomicInteger wip

Constructor Detail

ExecutorWorker	back to summary
public ExecutorWorker(Executor executor, boolean interruptibleWorker)

Method Detail

dispose	back to summary
public void dispose() Implements io.reactivex.disposables.Disposable.dispose. Doc from io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Doc from io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

run	back to summary
public void run() Implements java.lang.Runnable.run. Doc from java.lang.Runnable.run. Runs this operation. Annotations @Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

schedule back to summary

schedule	back to summary
public Disposable schedule(Runnable run) Overrides io.reactivex.Scheduler.Worker.schedule. Doc from io.reactivex.Scheduler.Worker.schedule. Schedules a Runnable for execution without any time delay. The default implementation delegates to `schedule(Runnable, long, TimeUnit)`. Parameters run:Runnable Runnable to schedule Returns:Disposable a Disposable to be able to unsubscribe the action (cancel it if not executed) Annotations @NonNull @Override

public Disposable schedule(Runnable run)

Overrides io.reactivex.Scheduler.Worker.schedule.

Doc from io.reactivex.Scheduler.Worker.schedule.

Schedules a Runnable for execution without any time delay.

The default implementation delegates to schedule(Runnable, long, TimeUnit).

Parameters

run:Runnable: Runnable to schedule

Returns:Disposable

a Disposable to be able to unsubscribe the action (cancel it if not executed)

Annotations

@NonNull
@Override

schedule back to summary

schedule	back to summary
public Disposable schedule(Runnable run, long delay, TimeUnit unit) Implements abstract io.reactivex.Scheduler.Worker.schedule. Doc from io.reactivex.Scheduler.Worker.schedule. Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time. Note to implementors: non-positive `delayTime` should be regarded as non-delayed schedule, i.e., as if the `schedule(Runnable)` was called. Parameters run:Runnable the Runnable to schedule delay:long time to "wait" before executing the action; non-positive values indicate an non-delayed schedule unit:TimeUnit the time unit of `delayTime` Returns:Disposable a Disposable to be able to unsubscribe the action (cancel it if not executed) Annotations @NonNull @Override

public Disposable schedule(Runnable run, long delay, TimeUnit unit)

Implements abstract io.reactivex.Scheduler.Worker.schedule.

Doc from io.reactivex.Scheduler.Worker.schedule.

Schedules an Runnable for execution at some point in the future specified by a time delay relative to the current time.

Note to implementors: non-positive delayTime should be regarded as non-delayed schedule, i.e., as if the schedule(Runnable) was called.

Parameters

run:Runnable: the Runnable to schedule
delay:long: time to "wait" before executing the action; non-positive values indicate an non-delayed schedule
unit:TimeUnit: the time unit of delayTime

Returns:Disposable

a Disposable to be able to unsubscribe the action (cancel it if not executed)

Annotations

@NonNull
@Override

io.reactivex.internal.schedulers back to summary

pack-priv final Class ExecutorScheduler.ExecutorWorker.BooleanRunnable

Class Inheritance

extends AtomicBoolean
implements Runnable, Disposable

java.lang.Object
java.util.concurrent.atomic.AtomicBoolean
io.reactivex.internal.schedulers.ExecutorScheduler.ExecutorWorker.BooleanRunnable

All Implemented Interfaces

io.reactivex.disposables.Disposable, java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
pack-priv final Runnable	actual
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicBoolean.serialVersionUID.

Constructor Summary

Access	Constructor and Description
pack-priv	BooleanRunnable(Runnable actual)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Field Detail

actual	back to summary
pack-priv final Runnable actual

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicBoolean.serialVersionUID.

Constructor Detail

BooleanRunnable	back to summary
pack-priv BooleanRunnable(Runnable actual)

Method Detail

dispose

back to summary

public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.reactivex.internal.schedulers back to summary

pack-priv final Class ExecutorScheduler.ExecutorWorker.InterruptibleRunnable

Class Inheritance

extends AtomicInteger
implements Runnable, Disposable

java.lang.Object
java.lang.Number
java.util.concurrent.atomic.AtomicInteger
io.reactivex.internal.schedulers.ExecutorScheduler.ExecutorWorker.InterruptibleRunnable

All Implemented Interfaces

io.reactivex.disposables.Disposable, java.lang.Runnable

Wrapper for a Runnable with additional logic for handling interruption on a shared thread, similar to how Java Executors do it.

Field Summary

Modifier and Type	Field and Description
pack-priv static final int	FINISHED
pack-priv static final int	INTERRUPTED
pack-priv static final int	INTERRUPTING
pack-priv static final int	READY
pack-priv final Runnable	run
pack-priv static final int	RUNNING
private static final long	serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.
pack-priv final DisposableContainer	tasks
pack-priv volatile Thread	thread

Constructor Summary

Access	Constructor and Description
pack-priv	InterruptibleRunnable(Runnable run, DisposableContainer tasks)

Method Summary

Modifier and Type	Method and Description
pack-priv void	cleanup()
public void	dispose() Implements io.reactivex.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Field Detail

FINISHED	back to summary
pack-priv static final int FINISHED

INTERRUPTED	back to summary
pack-priv static final int INTERRUPTED

INTERRUPTING	back to summary
pack-priv static final int INTERRUPTING

READY	back to summary
pack-priv static final int READY

run	back to summary
pack-priv final Runnable run

RUNNING	back to summary
pack-priv static final int RUNNING

serialVersionUID	back to summary
private static final long serialVersionUID Hides java.util.concurrent.atomic.AtomicInteger.serialVersionUID.

tasks	back to summary
pack-priv final DisposableContainer tasks

thread	back to summary
pack-priv volatile Thread thread

Constructor Detail

InterruptibleRunnable	back to summary
pack-priv InterruptibleRunnable(Runnable run, DisposableContainer tasks)

Method Detail

cleanup	back to summary
pack-priv void cleanup()

dispose

back to summary

public void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Doc from io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Doc from io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations

@Override

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override

io.reactivex.internal.schedulers back to summary

pack-priv final Class ExecutorScheduler.ExecutorWorker.SequentialDispose

Class Inheritance

extends Object
implements Runnable

java.lang.Object
io.reactivex.internal.schedulers.ExecutorScheduler.ExecutorWorker.SequentialDispose

All Implemented Interfaces

java.lang.Runnable

Field Summary

Modifier and Type	Field and Description
private final Runnable	decoratedRun
private final SequentialDisposable	mar

Constructor Summary

Access	Constructor and Description
pack-priv	SequentialDispose(SequentialDisposable mar, Runnable decoratedRun)

Method Summary

Modifier and Type	Method and Description
public void	run() Implements java.lang.Runnable.run. Runs this operation.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

decoratedRun	back to summary
private final Runnable decoratedRun

mar	back to summary
private final SequentialDisposable mar

Constructor Detail

SequentialDispose	back to summary
pack-priv SequentialDispose(SequentialDisposable mar, Runnable decoratedRun)

Method Detail

run

back to summary

public void run()

Implements java.lang.Runnable.run.

Doc from java.lang.Runnable.run.

Runs this operation.

Annotations

@Override