Class TrampolineScheduler.InnerCurrentThreadScheduler

java.lang.Object
rx.Scheduler.Worker
rx.internal.schedulers.TrampolineScheduler.InnerCurrentThreadScheduler
All Implemented Interfaces:
Subscription
Enclosing class:
TrampolineScheduler

static final class TrampolineScheduler.InnerCurrentThreadScheduler extends Scheduler.Worker implements Subscription
  • Field Details

  • Constructor Details

    • InnerCurrentThreadScheduler

      InnerCurrentThreadScheduler()
  • 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)
    • 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)
    • enqueue

      private Subscription enqueue(Action0 action, long execTime)
    • 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
    • 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