Class TestServiceProvider

Inheritance
System.Object
TestServiceProvider
AssertionTestServiceProvider
Namespace: Reaqtor.TestingFramework
Assembly: Reaqtor.TestingFramework.Service.dll
Syntax
public class TestServiceProvider : Object, IReactiveServiceProvider, IReactiveServiceProvider<Expression>, IReactiveMetadataServiceProvider, IReactiveClientServiceProvider, IReactiveClientServiceProvider<Expression>, IReactiveDefinitionServiceProvider, IReactiveDefinitionServiceProvider<Expression>

Constructors

TestServiceProvider()

Declaration
public TestServiceProvider()

Properties

Provider

Declaration
public IQueryProvider Provider { get; }
Property Value
Type Description
System.Linq.IQueryProvider

Methods

AssertCreateStream(Uri, Expression, Object)

Declaration
protected virtual void AssertCreateStream(Uri streamUri, Expression stream, object state)
Parameters
Type Name Description
System.Uri streamUri
System.Linq.Expressions.Expression stream
System.Object state

AssertCreateSubscription(Uri, Expression, Object)

Declaration
protected virtual void AssertCreateSubscription(Uri subscriptionUri, Expression subscription, object state)
Parameters
Type Name Description
System.Uri subscriptionUri
System.Linq.Expressions.Expression subscription
System.Object state

AssertDefineObservable(Uri, Expression, Object)

Declaration
protected virtual void AssertDefineObservable(Uri observableUri, Expression observable, object state)
Parameters
Type Name Description
System.Uri observableUri
System.Linq.Expressions.Expression observable
System.Object state

AssertDefineObserver(Uri, Expression, Object)

Declaration
protected virtual void AssertDefineObserver(Uri observerUri, Expression observer, object state)
Parameters
Type Name Description
System.Uri observerUri
System.Linq.Expressions.Expression observer
System.Object state

AssertDefineStreamFactory(Uri, Expression, Object)

Declaration
protected virtual void AssertDefineStreamFactory(Uri streamFactoryUri, Expression streamFactory, object state)
Parameters
Type Name Description
System.Uri streamFactoryUri
System.Linq.Expressions.Expression streamFactory
System.Object state

AssertDefineSubscriptionFactory(Uri, Expression, Object)

Declaration
protected virtual void AssertDefineSubscriptionFactory(Uri subscriptionFactoryUri, Expression subscriptionFactory, object state)
Parameters
Type Name Description
System.Uri subscriptionFactoryUri
System.Linq.Expressions.Expression subscriptionFactory
System.Object state

AssertDeleteStream(Uri)

Declaration
protected virtual void AssertDeleteStream(Uri streamUri)
Parameters
Type Name Description
System.Uri streamUri

AssertDeleteSubscription(Uri)

Declaration
protected virtual void AssertDeleteSubscription(Uri subscriptionUri)
Parameters
Type Name Description
System.Uri subscriptionUri

AssertMetadataQuery(Expression)

Declaration
public virtual void AssertMetadataQuery(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

AssertOnCompleted(Uri)

Declaration
protected virtual void AssertOnCompleted(Uri observerUri)
Parameters
Type Name Description
System.Uri observerUri

AssertOnError(Uri, Exception)

Declaration
protected virtual void AssertOnError(Uri observerUri, Exception error)
Parameters
Type Name Description
System.Uri observerUri
System.Exception error

AssertOnNext<T>(Uri, T)

Declaration
protected virtual void AssertOnNext<T>(Uri observerUri, T value)
Parameters
Type Name Description
System.Uri observerUri
T value
Type Parameters
Name Description
T

AssertUndefineObservable(Uri)

Declaration
protected virtual void AssertUndefineObservable(Uri observableUri)
Parameters
Type Name Description
System.Uri observableUri

AssertUndefineObserver(Uri)

Declaration
protected virtual void AssertUndefineObserver(Uri observerUri)
Parameters
Type Name Description
System.Uri observerUri

AssertUndefineStreamFactory(Uri)

Declaration
protected virtual void AssertUndefineStreamFactory(Uri streamFactoryUri)
Parameters
Type Name Description
System.Uri streamFactoryUri

AssertUndefineSubscriptionFactory(Uri)

Declaration
protected virtual void AssertUndefineSubscriptionFactory(Uri subscriptionFactoryUri)
Parameters
Type Name Description
System.Uri subscriptionFactoryUri

CreateStreamAsync(Uri, Expression, Object, CancellationToken)

Declaration
public Task CreateStreamAsync(Uri streamUri, Expression stream, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri streamUri
System.Linq.Expressions.Expression stream
System.Object state
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

CreateSubscriptionAsync(Uri, Expression, Object, CancellationToken)

Declaration
public Task CreateSubscriptionAsync(Uri subscriptionUri, Expression subscription, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri subscriptionUri
System.Linq.Expressions.Expression subscription
System.Object state
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

DefineObservableAsync(Uri, Expression, Object, CancellationToken)

Declaration
public Task DefineObservableAsync(Uri observableUri, Expression observable, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri observableUri
System.Linq.Expressions.Expression observable
System.Object state
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

DefineObserverAsync(Uri, Expression, Object, CancellationToken)

Declaration
public Task DefineObserverAsync(Uri observerUri, Expression observer, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri observerUri
System.Linq.Expressions.Expression observer
System.Object state
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

DefineStreamFactoryAsync(Uri, Expression, Object, CancellationToken)

Declaration
public Task DefineStreamFactoryAsync(Uri streamFactoryUri, Expression streamFactory, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri streamFactoryUri
System.Linq.Expressions.Expression streamFactory
System.Object state
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

DefineSubscriptionFactoryAsync(Uri, Expression, Object, CancellationToken)

Declaration
public Task DefineSubscriptionFactoryAsync(Uri subscriptionFactoryUri, Expression subscriptionFactory, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri subscriptionFactoryUri
System.Linq.Expressions.Expression subscriptionFactory
System.Object state
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

DeleteStreamAsync(Uri, CancellationToken)

Declaration
public Task DeleteStreamAsync(Uri streamUri, CancellationToken token)
Parameters
Type Name Description
System.Uri streamUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

DeleteSubscriptionAsync(Uri, CancellationToken)

Declaration
public Task DeleteSubscriptionAsync(Uri subscriptionUri, CancellationToken token)
Parameters
Type Name Description
System.Uri subscriptionUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

GetObserverAsync<T>(Uri, CancellationToken)

Declaration
public Task<IAsyncReactiveObserver<T>> GetObserverAsync<T>(Uri observerUri, CancellationToken token)
Parameters
Type Name Description
System.Uri observerUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task<IAsyncReactiveObserver<T>>
Type Parameters
Name Description
T

UndefineObservableAsync(Uri, CancellationToken)

Declaration
public Task UndefineObservableAsync(Uri observableUri, CancellationToken token)
Parameters
Type Name Description
System.Uri observableUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

UndefineObserverAsync(Uri, CancellationToken)

Declaration
public Task UndefineObserverAsync(Uri observerUri, CancellationToken token)
Parameters
Type Name Description
System.Uri observerUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

UndefineStreamFactoryAsync(Uri, CancellationToken)

Declaration
public Task UndefineStreamFactoryAsync(Uri streamFactoryUri, CancellationToken token)
Parameters
Type Name Description
System.Uri streamFactoryUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

UndefineSubscriptionFactoryAsync(Uri, CancellationToken)

Declaration
public Task UndefineSubscriptionFactoryAsync(Uri subscriptionFactoryUri, CancellationToken token)
Parameters
Type Name Description
System.Uri subscriptionFactoryUri
System.Threading.CancellationToken token
Returns
Type Description
System.Threading.Tasks.Task

Implements