hu.akarnokd.rxjava2.schedulers

Class TestScheduler

java.lang.Object

hu.akarnokd.rxjava2.Scheduler

hu.akarnokd.rxjava2.schedulers.TestScheduler

public final class TestScheduler
extends Scheduler

A special, non thread-safe scheduler for testing operators that require a scheduler without introducing real concurrency and allows manually advancing a virtual time.

Nested Class Summary

Nested classes/interfaces inherited from class hu.akarnokd.rxjava2.Scheduler

Scheduler.Worker

Constructor Summary

Constructors

Constructor and Description
TestScheduler()

Method Summary

Modifier and Type	Method and Description
void	advanceTimeBy(long delayTime, java.util.concurrent.TimeUnit unit) Moves the Scheduler's clock forward by a specified amount of time.
void	advanceTimeTo(long delayTime, java.util.concurrent.TimeUnit unit) Moves the Scheduler's clock to a particular moment in time.
Scheduler.Worker	createWorker()
long	now(java.util.concurrent.TimeUnit unit) Returns the 'current time' of the Scheduler in the specified time unit.
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.

Methods inherited from class hu.akarnokd.rxjava2.Scheduler

scheduleDirect, scheduleDirect, schedulePeriodicallyDirect, shutdown, start

Methods inherited from class java.lang.Object

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

Constructor Detail

TestScheduler

public TestScheduler()

Method Detail

now

public long now(java.util.concurrent.TimeUnit unit)

Description copied from class: Scheduler

Returns the 'current time' of the Scheduler in the specified time unit.

Overrides:

now in class Scheduler

Parameters:

unit - the time unit

Returns:

the 'current time'

advanceTimeBy

public void advanceTimeBy(long delayTime,
                          java.util.concurrent.TimeUnit unit)

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

Parameters:

delayTime - the amount of time to move the Scheduler's clock forward

unit - the units of time that delayTime is expressed in

advanceTimeTo

public void advanceTimeTo(long delayTime,
                          java.util.concurrent.TimeUnit unit)

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

Parameters:

delayTime - the point in time to move the Scheduler's clock to

unit - the units of time that delayTime is expressed in

triggerActions

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.

createWorker

public Scheduler.Worker createWorker()

Specified by:

createWorker in class Scheduler