Package rx.internal.schedulers
Class SchedulerWhen.DelayedAction
java.lang.Object
java.util.concurrent.atomic.AtomicReference<Subscription>
rx.internal.schedulers.SchedulerWhen.ScheduledAction
rx.internal.schedulers.SchedulerWhen.DelayedAction
- All Implemented Interfaces:
Serializable
,Subscription
- Enclosing class:
SchedulerWhen
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprotected Subscription
callActual
(Scheduler.Worker actualWorker) Methods inherited from class rx.internal.schedulers.SchedulerWhen.ScheduledAction
isUnsubscribed, unsubscribe
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
- Specified by:
callActual
in classSchedulerWhen.ScheduledAction
-