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
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Disposable
callActual
(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) Methods inherited from class io.reactivex.rxjava3.internal.schedulers.SchedulerWhen.ScheduledAction
call, dispose, isDisposed
Methods inherited from class java.util.concurrent.atomic.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
-
Field Details
-
action
-
delayTime
private final long delayTime -
unit
-
-
Constructor Details
-
DelayedAction
-
-
Method Details
-
callActual
protected Disposable callActual(Scheduler.Worker actualWorker, CompletableObserver actionCompletable) - Specified by:
callActual
in classSchedulerWhen.ScheduledAction
-