Class SchedulerWhen.DelayedAction

java.lang.Object

java.util.concurrent.atomic.AtomicReference<Disposable>

io.reactivex.rxjava3.internal.schedulers.SchedulerWhen.ScheduledAction

io.reactivex.rxjava3.internal.schedulers.SchedulerWhen.DelayedAction

All Implemented Interfaces:

Disposable, Serializable

Enclosing class:

SchedulerWhen

static class SchedulerWhen.DelayedAction
extends SchedulerWhen.ScheduledAction

Since:

2.1

Field Summary

Fields

Modifier and Type	Field	Description
private final Runnable	action
private final long	delayTime
private final TimeUnit	unit

Constructor Summary

Constructors

Constructor	Description
DelayedAction(Runnable action, long delayTime, TimeUnit unit)

Method Summary

Modifier and Type	Method	Description
protected Disposable	callActual(Scheduler.Worker actualWorker, CompletableObserver actionCompletable)

Methods inherited from class SchedulerWhen.ScheduledAction

call, dispose, isDisposed

Methods inherited from class AtomicReference

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, set, setOpaque, setPlain, setRelease, toString, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Object

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

Field Details

action

private final Runnable action

delayTime

private final long delayTime

unit

private final TimeUnit unit

Constructor Details

DelayedAction

DelayedAction(Runnable action,
 long delayTime,
 TimeUnit unit)

Method Details

callActual

protected Disposable callActual(Scheduler.Worker actualWorker,
 CompletableObserver actionCompletable)

Specified by:

callActual in class SchedulerWhen.ScheduledAction