Class TestExecutionEnvironment

Inheritance
System.Object
TestExecutionEnvironment
Namespace: Reaqtor.TestingFramework
Assembly: Reaqtor.TestingFramework.Hosted.dll
Syntax
public class TestExecutionEnvironment : Object, IHigherOrderExecutionEnvironment, IExecutionEnvironment

Constructors

TestExecutionEnvironment()

Declaration
public TestExecutionEnvironment()

Properties

ArtifactCount

Declaration
public int ArtifactCount { get; }
Property Value
Type Description
System.Int32

BridgeSubscriptionError

Declaration
public Exception BridgeSubscriptionError { get; set; }
Property Value
Type Description
System.Exception

Reactive

Declaration
public IReactive Reactive { get; }
Property Value
Type Description
IReactive

Methods

AddArtifact(Uri, Object)

Declaration
public void AddArtifact(Uri uri, object artifact)
Parameters
Type Name Description
System.Uri uri
System.Object artifact

CreateBridge<T>(ISubscribable<T>, IObserver<T>, IOperatorContext)

Declaration
public ISubscription CreateBridge<T>(ISubscribable<T> subscribable, IObserver<T> observer, IOperatorContext parent)
Parameters
Type Name Description
ISubscribable<T> subscribable
System.IObserver<T> observer
IOperatorContext parent
Returns
Type Description
ISubscription
Type Parameters
Name Description
T

CreateRefCountSubject<T>(Uri, Uri, Uri, IOperatorContext)

Declaration
public IMultiSubject<T, T> CreateRefCountSubject<T>(Uri uri, Uri tollbooth, Uri collector, IOperatorContext parent)
Parameters
Type Name Description
System.Uri uri
System.Uri tollbooth
System.Uri collector
IOperatorContext parent
Returns
Type Description
IMultiSubject<T, T>
Type Parameters
Name Description
T

CreateSimpleSubject<T>(Uri, IOperatorContext)

Declaration
public IMultiSubject<T, T> CreateSimpleSubject<T>(Uri uri, IOperatorContext parent)
Parameters
Type Name Description
System.Uri uri
IOperatorContext parent
Returns
Type Description
IMultiSubject<T, T>
Type Parameters
Name Description
T

Defrost()

Declaration
public void Defrost()

DeleteSubject<T>(Uri, IOperatorContext)

Declaration
public void DeleteSubject<T>(Uri uri, IOperatorContext parent)
Parameters
Type Name Description
System.Uri uri
IOperatorContext parent
Type Parameters
Name Description
T

Freeze()

Declaration
public void Freeze()

GetArtifact(Uri)

Declaration
protected object GetArtifact(Uri uri)
Parameters
Type Name Description
System.Uri uri
Returns
Type Description
System.Object

GetSubject<TInput, TOutput>(Uri)

Declaration
public IMultiSubject<TInput, TOutput> GetSubject<TInput, TOutput>(Uri uri)
Parameters
Type Name Description
System.Uri uri
Returns
Type Description
IMultiSubject<TInput, TOutput>
Type Parameters
Name Description
TInput
TOutput

GetSubscription(Uri)

Declaration
public ISubscription GetSubscription(Uri uri)
Parameters
Type Name Description
System.Uri uri
Returns
Type Description
ISubscription

LoadBridge<T>(IOperatorStateReader, IObserver<T>, IOperatorContext)

Declaration
public ISubscription LoadBridge<T>(IOperatorStateReader reader, IObserver<T> observer, IOperatorContext parent)
Parameters
Type Name Description
IOperatorStateReader reader
System.IObserver<T> observer
IOperatorContext parent
Returns
Type Description
ISubscription
Type Parameters
Name Description
T

Quote<T>(IMultiSubject<T, T>, Uri)

Declaration
public ISubscribable<T> Quote<T>(IMultiSubject<T, T> subject, Uri uri)
Parameters
Type Name Description
IMultiSubject<T, T> subject
System.Uri uri
Returns
Type Description
ISubscribable<T>
Type Parameters
Name Description
T

Quote<TKey, TElement>(IGroupedMultiSubject<TKey, TElement>, Uri)

Declaration
public IGroupedSubscribable<TKey, TElement> Quote<TKey, TElement>(IGroupedMultiSubject<TKey, TElement> subject, Uri uri)
Parameters
Type Name Description
IGroupedMultiSubject<TKey, TElement> subject
System.Uri uri
Returns
Type Description
IGroupedSubscribable<TKey, TElement>
Type Parameters
Name Description
TKey
TElement

RemoveArtifact(Uri)

Declaration
public void RemoveArtifact(Uri uri)
Parameters
Type Name Description
System.Uri uri

SaveBridge(ISubscription, IOperatorStateWriter, IOperatorContext)

Declaration
public void SaveBridge(ISubscription subscription, IOperatorStateWriter writer, IOperatorContext parent)
Parameters
Type Name Description
ISubscription subscription
IOperatorStateWriter writer
IOperatorContext parent

TryGetSubject<TInput, TOutput>(Uri, out IMultiSubject<TInput, TOutput>)

Declaration
public bool TryGetSubject<TInput, TOutput>(Uri uri, out IMultiSubject<TInput, TOutput> subject)
Parameters
Type Name Description
System.Uri uri
IMultiSubject<TInput, TOutput> subject
Returns
Type Description
System.Boolean
Type Parameters
Name Description
TInput
TOutput

Implements