Class ExecutorScheduler.ExecutorSchedulerWorker

java.lang.Object
rx.Scheduler.Worker
rx.internal.schedulers.ExecutorScheduler.ExecutorSchedulerWorker
All Implemented Interfaces:
Runnable, Subscription
Enclosing class:
ExecutorScheduler

static final class ExecutorScheduler.ExecutorSchedulerWorker extends Scheduler.Worker implements Runnable
Worker that schedules tasks on the executor indirectly through a trampoline mechanism.
  • Field Details

  • Constructor Details

    • ExecutorSchedulerWorker

      public ExecutorSchedulerWorker(Executor executor)
  • Method Details

    • schedule

      public Subscription schedule(Action0 action)
      Description copied from class: Scheduler.Worker
      Schedules an Action for execution.
      Specified by:
      schedule in class Scheduler.Worker
      Parameters:
      action - Action to schedule
      Returns:
      a subscription to be able to unsubscribe the action (unschedule it if not executed)
    • run

      public void run()
      Specified by:
      run in interface Runnable
    • schedule

      public Subscription schedule(Action0 action, long delayTime, TimeUnit unit)
      Description copied from class: Scheduler.Worker
      Schedules an Action for execution at some point in the future.

      Note to implementors: non-positive delayTime should be regarded as undelayed schedule, i.e., as if the Scheduler.Worker.schedule(rx.functions.Action0) was called.

      Specified by:
      schedule in class Scheduler.Worker
      Parameters:
      action - the Action to schedule
      delayTime - time to wait before executing the action; non-positive values indicate an undelayed schedule
      unit - the time unit of delayTime
      Returns:
      a subscription to be able to unsubscribe the action (unschedule it if not executed)
    • 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