Class TestSchedulerExtensions

Inheritance
System.Object
TestSchedulerExtensions
Namespace: Reaqtive.TestingFramework
Assembly: Reaqtive.TestingFramework.dll
Syntax
public static class TestSchedulerExtensions : Object

Methods

ScheduleAbsolute(TestScheduler, Int64, Action)

Declaration
public static void ScheduleAbsolute(this TestScheduler scheduler, long dueTime, Action action)
Parameters
Type Name Description
TestScheduler scheduler
System.Int64 dueTime
System.Action action

ScheduleRelative(TestScheduler, Int64, Action)

Declaration
public static void ScheduleRelative(this TestScheduler scheduler, long dueTime, Action action)
Parameters
Type Name Description
TestScheduler scheduler
System.Int64 dueTime
System.Action action

Start<T>(TestScheduler, IOperatorContext, Func<ISubscribable<T>>, Int64, Int64, Int64, IOperatorStateContainer)

Declaration
public static ITestableObserver<T> Start<T>(this TestScheduler scheduler, IOperatorContext context, Func<ISubscribable<T>> create, long created, long subscribed, long disposed, IOperatorStateContainer recovery = null)
Parameters
Type Name Description
TestScheduler scheduler
IOperatorContext context
System.Func<ISubscribable<T>> create
System.Int64 created
System.Int64 subscribed
System.Int64 disposed
IOperatorStateContainer recovery
Returns
Type Description
Reaqtive.Testing.ITestableObserver<T>
Type Parameters
Name Description
T

Start<T>(TestScheduler, Func<ISubscribable<T>>)

Declaration
public static ITestableObserver<T> Start<T>(this TestScheduler scheduler, Func<ISubscribable<T>> create)
Parameters
Type Name Description
TestScheduler scheduler
System.Func<ISubscribable<T>> create
Returns
Type Description
Reaqtive.Testing.ITestableObserver<T>
Type Parameters
Name Description
T

Start<T>(TestScheduler, Func<ISubscribable<T>>, Int64)

Declaration
public static ITestableObserver<T> Start<T>(this TestScheduler scheduler, Func<ISubscribable<T>> create, long disposed)
Parameters
Type Name Description
TestScheduler scheduler
System.Func<ISubscribable<T>> create
System.Int64 disposed
Returns
Type Description
Reaqtive.Testing.ITestableObserver<T>
Type Parameters
Name Description
T

Start<T>(TestScheduler, Func<ISubscribable<T>>, Int64, Int64, Int64, IOperatorStateContainer)

Declaration
public static ITestableObserver<T> Start<T>(this TestScheduler scheduler, Func<ISubscribable<T>> create, long created, long subscribed, long disposed, IOperatorStateContainer recovery = null)
Parameters
Type Name Description
TestScheduler scheduler
System.Func<ISubscribable<T>> create
System.Int64 created
System.Int64 subscribed
System.Int64 disposed
IOperatorStateContainer recovery
Returns
Type Description
Reaqtive.Testing.ITestableObserver<T>
Type Parameters
Name Description
T