Package rx.schedulers

Class TestScheduler.InnerTestScheduler

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean isUnsubscribed()
      Indicates whether this Subscription is currently unsubscribed.
      long now()
      Gets the current time, in milliseconds, according to this Scheduler.
      Subscription schedule​(Action0 action)
      Schedules an Action for execution.
      Subscription schedule​(Action0 action, long delayTime, java.util.concurrent.TimeUnit unit)
      Schedules an Action for execution at some point in the future.
      void unsubscribe()
      Stops the receipt of notifications on the Subscriber that was registered when this Subscription was received.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • InnerTestScheduler

        InnerTestScheduler()

    • Method Detail

      • 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,
                             java.util.concurrent.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