Package rx.schedulers

Class TestScheduler.InnerTestScheduler

java.lang.Object
rx.Scheduler.Worker
rx.schedulers.TestScheduler.InnerTestScheduler
All Implemented Interfaces:
Subscription
Enclosing class:
TestScheduler

final class TestScheduler.InnerTestScheduler extends Scheduler.Worker
  • Field Details

  • Constructor Details

    • InnerTestScheduler

      InnerTestScheduler()
  • Method Details

    • 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).

    • isUnsubscribed

      public boolean isUnsubscribed()
      Description copied from interface: Subscription
      Indicates whether this Subscription is currently unsubscribed.
      Returns:
      true if this Subscription is currently unsubscribed, false otherwise
    • 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)
    • 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)
    • now

      public long now()
      Description copied from class: Scheduler.Worker
      Gets the current time, in milliseconds, according to this Scheduler.
      Overrides:
      now in class Scheduler.Worker
      Returns:
      the scheduler's notion of current absolute time in milliseconds