Class TestScheduler

Inheritance
System.Object
VirtualTimeLogicalScheduler<System.Int64, System.Int64>
TestScheduler
LoggingTestScheduler
Implements
IClockable<System.Int64>
System.IDisposable
Inherited Members
Namespace: Reaqtive.TestingFramework
Assembly: Reaqtive.TestingFramework.dll
Syntax
public class TestScheduler : VirtualTimeLogicalScheduler<long, long>, ISchedulerExceptionHandler, ITestScheduler, IClockable<long>, IScheduler, IDisposable

Constructors

TestScheduler()

Declaration
public TestScheduler()

TestScheduler(TestScheduler)

Declaration
protected TestScheduler(TestScheduler parent)
Parameters
Type Name Description
TestScheduler parent

Properties

Increment

Declaration
public virtual long Increment { get; }
Property Value
Type Description
System.Int64

Methods

CreateChildScheduler()

Declaration
public override IScheduler CreateChildScheduler()
Returns
Type Description
IScheduler
Overrides
Reaqtive.TestingFramework.VirtualTimeLogicalScheduler<System.Int64, System.Int64>.CreateChildScheduler()

CreateChildTestScheduler()

Declaration
public TestScheduler CreateChildTestScheduler()
Returns
Type Description
TestScheduler

CreateColdObservable<T>(Recorded<Notification<T>>[])

Declaration
public ITestableSubscribable<T> CreateColdObservable<T>(params Recorded<Notification<T>>[] messages)
Parameters
Type Name Description
Reaqtive.Testing.Recorded<Reaqtive.Notification<T>>[] messages
Returns
Type Description
ITestableSubscribable<T>
Type Parameters
Name Description
T

CreateContext(IExecutionEnvironment, TraceSource, IDictionary<String, Object>)

Declaration
public IOperatorContext CreateContext(IExecutionEnvironment environment = null, TraceSource trace = null, IDictionary<string, object> settings = null)
Parameters
Type Name Description
IExecutionEnvironment environment
System.Diagnostics.TraceSource trace
System.Collections.Generic.IDictionary<System.String, System.Object> settings
Returns
Type Description
IOperatorContext

CreateHotObservable<T>(Recorded<Notification<T>>[])

Declaration
public ITestableSubscribable<T> CreateHotObservable<T>(params Recorded<Notification<T>>[] messages)
Parameters
Type Name Description
Reaqtive.Testing.Recorded<Reaqtive.Notification<T>>[] messages
Returns
Type Description
ITestableSubscribable<T>
Type Parameters
Name Description
T

CreateObserver<T>()

Declaration
public ITestableObserver<T> CreateObserver<T>()
Returns
Type Description
Reaqtive.Testing.ITestableObserver<T>
Type Parameters
Name Description
T

CreateStateContainer()

Declaration
public IOperatorStateContainer CreateStateContainer()
Returns
Type Description
IOperatorStateContainer

ScheduleAbsolute(Int64, ISchedulerTask)

Declaration
public override void ScheduleAbsolute(long dueTime, ISchedulerTask task)
Parameters
Type Name Description
System.Int64 dueTime
ISchedulerTask task
Overrides
Reaqtive.TestingFramework.VirtualTimeLogicalScheduler<System.Int64, System.Int64>.ScheduleAbsolute(System.Int64, Reaqtive.Scheduler.ISchedulerTask)

ScheduleAbsolute<TState>(TState, Int64, Action<IScheduler, TState>)

Declaration
public void ScheduleAbsolute<TState>(TState state, long dueTime, Action<IScheduler, TState> action)
Parameters
Type Name Description
TState state
System.Int64 dueTime
System.Action<IScheduler, TState> action
Type Parameters
Name Description
TState

ScheduleRelative<TState>(TState, Int64, Action<IScheduler, TState>)

Declaration
public void ScheduleRelative<TState>(TState state, long dueTime, Action<IScheduler, TState> action)
Parameters
Type Name Description
TState state
System.Int64 dueTime
System.Action<IScheduler, TState> action
Type Parameters
Name Description
TState

Implements

System.IDisposable

Extension Methods