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

private static class SchedulerWhen.DelayedAction
extends SchedulerWhen.ScheduledAction

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
protected 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

Methods inherited from class java.lang.Object

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

Field Details

action

private final Action0 action

delayTime

private final long delayTime

unit

private final TimeUnit unit

Constructor Details

DelayedAction

public DelayedAction(Action0 action,
 long delayTime,
 TimeUnit unit)

Method Details

callActual

protected Subscription callActual(Scheduler.Worker actualWorker)

Specified by:

callActual in class SchedulerWhen.ScheduledAction