Modifier and Type	Class and Description
pack-priv static class	TestScheduler.CompareActionsByTime
pack-priv class	TestScheduler.InnerTestScheduler
pack-priv static class	TestScheduler.TimedAction

Modifier and Type	Field and Description
pack-priv static long	counter
pack-priv final Queue<TestScheduler.TimedAction>	queue
pack-priv long	time

Access	Constructor and Description
public	TestScheduler()

Modifier and Type	Method and Description
public void	advanceTimeBy(long the amount of time to move the Scheduler's clock forward delayTime, TimeUnit the units of time that `delayTime` is expressed in unit) Moves the Scheduler's clock forward by a specified amount of time.
public void	advanceTimeTo(long the point in time to move the Scheduler's clock to delayTime, TimeUnit the units of time that `delayTime` is expressed in unit) Moves the Scheduler's clock to a particular moment in time.
public Scheduler.Worker	createWorker() Implements abstract rx.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents serial execution of actions.
public long	now() Overrides rx.Scheduler.now. Gets the current time, in milliseconds, according to this Scheduler.
public void	triggerActions() Triggers any actions that have not yet been triggered and that are scheduled to be triggered at or before this Scheduler's present time.
private void	triggerActions(long targetTimeInNanos)

counter	back to summary
pack-priv static long counter

queue	back to summary
pack-priv final Queue<TestScheduler.TimedAction> queue

time	back to summary
pack-priv long time

TestScheduler	back to summary
public TestScheduler()

Method Detail

advanceTimeBy back to summary

advanceTimeBy	back to summary
public void advanceTimeBy(long delayTime, TimeUnit unit) Moves the Scheduler's clock forward by a specified amount of time. Parameters delayTime:long the amount of time to move the Scheduler's clock forward unit:TimeUnit the units of time that `delayTime` is expressed in

public void advanceTimeBy(long delayTime, TimeUnit unit)

Moves the Scheduler's clock forward by a specified amount of time.

Parameters

delayTime:long: the amount of time to move the Scheduler's clock forward
unit:TimeUnit: the units of time that delayTime is expressed in

advanceTimeTo back to summary

advanceTimeTo	back to summary
public void advanceTimeTo(long delayTime, TimeUnit unit) Moves the Scheduler's clock to a particular moment in time. Parameters delayTime:long the point in time to move the Scheduler's clock to unit:TimeUnit the units of time that `delayTime` is expressed in

public void advanceTimeTo(long delayTime, TimeUnit unit)

Moves the Scheduler's clock to a particular moment in time.

Parameters

delayTime:long: the point in time to move the Scheduler's clock to
unit:TimeUnit: the units of time that delayTime is expressed in

createWorker back to summary

createWorker	back to summary
public Scheduler.Worker createWorker() Implements abstract rx.Scheduler.createWorker. Doc from rx.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents serial execution of actions. When work is completed it should be unsubscribed using `Scheduler.Worker#unsubscribe()`. Work on a `Scheduler.Worker` is guaranteed to be sequential. Returns:Scheduler.Worker a Worker representing a serial queue of actions to be executed Annotations @Override

public Scheduler.Worker createWorker()

Implements abstract rx.Scheduler.createWorker.

Doc from rx.Scheduler.createWorker.

Retrieves or creates a new Scheduler.Worker that represents serial execution of actions.

When work is completed it should be unsubscribed using Scheduler.Worker#unsubscribe().

Work on a Scheduler.Worker is guaranteed to be sequential.

Returns:Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations

@Override

now	back to summary
public long now() Overrides rx.Scheduler.now. Doc from rx.Scheduler.now. Gets the current time, in milliseconds, according to this Scheduler. Returns:long the scheduler's notion of current absolute time in milliseconds Annotations @Override

now

back to summary

public long now()

Overrides rx.Scheduler.now.

Doc from rx.Scheduler.now.

Gets the current time, in milliseconds, according to this Scheduler.

Returns:long

the scheduler's notion of current absolute time in milliseconds

Annotations

@Override

triggerActions	back to summary
public void triggerActions() Triggers any actions that have not yet been triggered and that are scheduled to be triggered at or before this Scheduler's present time.

triggerActions	back to summary
private void triggerActions(long targetTimeInNanos)

rx.schedulers back to summary

pack-priv final Class TestScheduler.CompareActionsByTime

Class Inheritance

extends Object
implements Comparator<TestScheduler.TimedAction>

java.lang.Object
rx.schedulers.TestScheduler.CompareActionsByTime

All Implemented Interfaces

java.util.Comparator

Constructor Summary

Access	Constructor and Description
pack-priv	CompareActionsByTime()

Method Summary

Modifier and Type	Method and Description
public int	compare(TestScheduler.TimedAction the first object to be compared. action1, TestScheduler.TimedAction the second object to be compared. action2) Implements java.util.Comparator.compare. Compares its two arguments for order.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Constructor Detail

CompareActionsByTime	back to summary
pack-priv CompareActionsByTime()

Method Detail

compare back to summary

compare	back to summary
public int compare(TestScheduler.TimedAction action1, TestScheduler.TimedAction action2) Implements java.util.Comparator.compare. Doc from java.util.Comparator.compare. Compares its two arguments for order. Returns a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second. The implementor must ensure that `signum(compare(x, y)) == -signum(compare(y, x))` for all `x` and `y`. (This implies that `compare(x, y)` must throw an exception if and only if `compare(y, x)` throws an exception.) The implementor must also ensure that the relation is transitive: `((compare(x, y)>0) && (compare(y, z)>0))` implies `compare(x, z)>0`. Finally, the implementor must ensure that `compare(x, y)==0` implies that `signum(compare(x, z))==signum(compare(y, z))` for all `z`. Parameters action1:TestScheduler.TimedAction the first object to be compared. action2:TestScheduler.TimedAction the second object to be compared. Returns:int a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second. Annotations @Override

public int compare(TestScheduler.TimedAction action1, TestScheduler.TimedAction action2)

Implements java.util.Comparator.compare.

Doc from java.util.Comparator.compare.

Compares its two arguments for order. Returns a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second.

The implementor must ensure that signum(compare(x, y)) == -signum(compare(y, x)) for all x and y. (This implies that compare(x, y) must throw an exception if and only if compare(y, x) throws an exception.)

The implementor must also ensure that the relation is transitive: ((compare(x, y)>0) && (compare(y, z)>0)) implies compare(x, z)>0.

Finally, the implementor must ensure that compare(x, y)==0 implies that signum(compare(x, z))==signum(compare(y, z)) for all z.

Parameters

action1:TestScheduler.TimedAction: the first object to be compared.
action2:TestScheduler.TimedAction: the second object to be compared.

Returns:int

a negative integer, zero, or a positive integer as the first argument is less than, equal to, or greater than the second.

Annotations

@Override

rx.schedulers back to summary

pack-priv final Class TestScheduler.InnerTestScheduler

Class Inheritance

extends Worker
implements NowNanoSupplier

java.lang.Object
rx.Scheduler.Worker
rx.schedulers.TestScheduler.InnerTestScheduler

All Implemented Interfaces

rx.internal.schedulers.SchedulePeriodicHelper.NowNanoSupplier

Field Summary

Modifier and Type	Field and Description
private final BooleanSubscription	s

Constructor Summary

Access	Constructor and Description
pack-priv	InnerTestScheduler()

Method Summary

Modifier and Type	Method and Description
public boolean	isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed.
public long	now() Overrides rx.Scheduler.Worker.now. Gets the current time, in milliseconds, according to this Scheduler.
public long	nowNanos() Implements rx.internal.schedulers.SchedulePeriodicHelper.NowNanoSupplier.nowNanos.
public Subscription	schedule(Action0 the Action to schedule action, long time to wait before executing the action; non-positive values indicate an non-delayed schedule delayTime, TimeUnit the time unit of `delayTime` unit) Implements abstract rx.Scheduler.Worker.schedule. Schedules an Action for execution at some point in the future.
public Subscription	schedule(Action0 Action to schedule action) Implements abstract rx.Scheduler.Worker.schedule. Schedules an Action for execution.
public Subscription	schedulePeriodically(Action0 the Action to execute periodically action, long time to wait before executing the action for the first time; non-positive values indicate an non-delayed schedule initialDelay, long the time interval to wait each time in between executing the action; non-positive values indicate no delay between repeated schedules period, TimeUnit the time unit of `period` unit) Overrides rx.Scheduler.Worker.schedulePeriodically. Schedules a cancelable action to be executed periodically.
public void	unsubscribe() Implements rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received.

Field Detail

s	back to summary
private final BooleanSubscription s

Constructor Detail

InnerTestScheduler	back to summary
pack-priv InnerTestScheduler()

Method Detail

isUnsubscribed back to summary

isUnsubscribed	back to summary
public boolean isUnsubscribed() Implements rx.Subscription.isUnsubscribed. Doc from rx.Subscription.isUnsubscribed. Indicates whether this `Subscription` is currently unsubscribed. Returns:boolean `true` if this `Subscription` is currently unsubscribed, `false` otherwise Annotations @Override

public boolean isUnsubscribed()

Implements rx.Subscription.isUnsubscribed.

Doc from rx.Subscription.isUnsubscribed.

Indicates whether this Subscription is currently unsubscribed.

Returns:boolean

true if this Subscription is currently unsubscribed, false otherwise

Annotations

@Override

now	back to summary
public long now() Overrides rx.Scheduler.Worker.now. Doc from rx.Scheduler.Worker.now. Gets the current time, in milliseconds, according to this Scheduler. Returns:long the scheduler's notion of current absolute time in milliseconds Annotations @Override

now

back to summary

public long now()

Overrides rx.Scheduler.Worker.now.

Doc from rx.Scheduler.Worker.now.

Gets the current time, in milliseconds, according to this Scheduler.

Returns:long

the scheduler's notion of current absolute time in milliseconds

Annotations

@Override

nowNanos	back to summary
public long nowNanos() Implements rx.internal.schedulers.SchedulePeriodicHelper.NowNanoSupplier.nowNanos. Annotations @Override

nowNanos

back to summary

public long nowNanos()

Implements rx.internal.schedulers.SchedulePeriodicHelper.NowNanoSupplier.nowNanos.

Annotations

@Override

schedule back to summary

schedule	back to summary
public Subscription schedule(Action0 action, long delayTime, TimeUnit unit) Implements abstract rx.Scheduler.Worker.schedule. Doc from rx.Scheduler.Worker.schedule. Schedules an Action for execution at some point in the future. Note to implementors: non-positive `delayTime` should be regarded as non-delayed schedule, i.e., as if the `schedule(rx.functions.Action0)` was called. Parameters action:Action0 the Action to schedule delayTime:long time to wait before executing the action; non-positive values indicate an non-delayed schedule unit:TimeUnit the time unit of `delayTime` Returns:Subscription a subscription to be able to prevent or cancel the execution of the action Annotations @Override

public Subscription schedule(Action0 action, long delayTime, TimeUnit unit)

Implements abstract rx.Scheduler.Worker.schedule.

Doc from rx.Scheduler.Worker.schedule.

Schedules an Action for execution at some point in the future.

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

Parameters

action:Action0: the Action to schedule
delayTime:long: time to wait before executing the action; non-positive values indicate an non-delayed schedule
unit:TimeUnit: the time unit of delayTime

Returns:Subscription

a subscription to be able to prevent or cancel the execution of the action

Annotations

@Override

schedule	back to summary
public Subscription schedule(Action0 action) Implements abstract rx.Scheduler.Worker.schedule. Doc from rx.Scheduler.Worker.schedule. Schedules an Action for execution. Parameters action:Action0 Action to schedule Returns:Subscription a subscription to be able to prevent or cancel the execution of the action Annotations @Override

schedule

back to summary

public Subscription schedule(Action0 action)

Implements abstract rx.Scheduler.Worker.schedule.

Doc from rx.Scheduler.Worker.schedule.

Schedules an Action for execution.

Parameters

action:Action0: Action to schedule

Returns:Subscription

a subscription to be able to prevent or cancel the execution of the action

Annotations

@Override

schedulePeriodically back to summary

schedulePeriodically	back to summary
public Subscription schedulePeriodically(Action0 action, long initialDelay, long period, TimeUnit unit) Overrides rx.Scheduler.Worker.schedulePeriodically. Doc from rx.Scheduler.Worker.schedulePeriodically. Schedules a cancelable action to be executed periodically. This default implementation schedules recursively and waits for actions to complete (instead of potentially executing long-running actions concurrently). Each scheduler that can do periodic scheduling in a better way should override this. Note to implementors: non-positive `initialTime` and `period` should be regarded as non-delayed scheduling of the first and any subsequent executions. Parameters action:Action0 the Action to execute periodically initialDelay:long time to wait before executing the action for the first time; non-positive values indicate an non-delayed schedule period:long the time interval to wait each time in between executing the action; non-positive values indicate no delay between repeated schedules unit:TimeUnit the time unit of `period` Returns:Subscription a subscription to be able to prevent or cancel the execution of the action Annotations @Override

public Subscription schedulePeriodically(Action0 action, long initialDelay, long period, TimeUnit unit)

Overrides rx.Scheduler.Worker.schedulePeriodically.

Doc from rx.Scheduler.Worker.schedulePeriodically.

Schedules a cancelable action to be executed periodically. This default implementation schedules recursively and waits for actions to complete (instead of potentially executing long-running actions concurrently). Each scheduler that can do periodic scheduling in a better way should override this.

Note to implementors: non-positive initialTime and period should be regarded as non-delayed scheduling of the first and any subsequent executions.

Parameters

action:Action0: the Action to execute periodically
initialDelay:long: time to wait before executing the action for the first time; non-positive values indicate an non-delayed schedule
period:long: the time interval to wait each time in between executing the action; non-positive values indicate no delay between repeated schedules
unit:TimeUnit: the time unit of period

Returns:Subscription

a subscription to be able to prevent or cancel the execution of the action

Annotations

@Override

unsubscribe back to summary

unsubscribe	back to summary
public void unsubscribe() Implements rx.Subscription.unsubscribe. Doc from rx.Subscription.unsubscribe. Stops the receipt of notifications on the `Subscriber` that was registered when this Subscription was received. This allows deregistering an `Subscriber` before it has finished receiving all events (i.e. before onCompleted is called). Annotations @Override

public void unsubscribe()

Implements rx.Subscription.unsubscribe.

Doc from rx.Subscription.unsubscribe.

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

This allows deregistering an Subscriber before it has finished receiving all events (i.e. before onCompleted is called).

Annotations

@Override

public Class TestScheduler

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class TestScheduler.CompareActionsByTime

Constructor Summary

Method Summary

Constructor Detail

Method Detail

pack-priv final Class TestScheduler.InnerTestScheduler

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

pack-priv final Class TestScheduler.TimedAction

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

Modifier and Type	Field and Description
pack-priv final Action0	action
private final long	count
pack-priv final Scheduler.Worker	scheduler
pack-priv final long	time