SchedulerWhen.ScheduledAction

java.lang.Object

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

rx.internal.schedulers.SchedulerWhen.ScheduledAction

All Implemented Interfaces:: Serializable, Subscription

Direct Known Subclasses:: SchedulerWhen.DelayedAction, SchedulerWhen.ImmediateAction

Enclosing class:: SchedulerWhen

private abstract static class SchedulerWhen.ScheduledAction extends AtomicReference<Subscription> implements Subscription

Constructor Summary

Constructors

Constructor

Description

ScheduledAction()
Method Summary

Modifier and Type

Method

Description

private final void

call(Scheduler.Worker actualWorker)

protected abstract Subscription

callActual(Scheduler.Worker actualWorker)

boolean

isUnsubscribed()

Indicates whether this Subscription is currently unsubscribed.

void

unsubscribe()

Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

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

Constructor Details
- ScheduledAction
  
  public ScheduledAction()
Method Details
- call
  
  private final void call(Scheduler.Worker actualWorker)
- callActual
  
  protected abstract Subscription callActual(Scheduler.Worker actualWorker)
- isUnsubscribed
  
  public boolean isUnsubscribed()
  
  Description copied from interface: Subscription
  
  Indicates whether this Subscription is currently unsubscribed.
  
  Specified by:
  
  isUnsubscribed in interface Subscription
  
  Returns:
  
  true if this Subscription is currently unsubscribed, false otherwise
- unsubscribe
  
  public void unsubscribe()
  
  Description copied from interface: Subscription
  
  Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.
  This allows unregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).
  
  Specified by:
  
  unsubscribe in interface Subscription