Class TestReliableEngineProvider
Inheritance
System.Object
TestReliableEngineProvider
Assembly: Reaqtor.TestingFramework.Reliable.dll
Syntax
public class TestReliableEngineProvider : Object, IReliableReactiveEngineProvider, IReliableReactiveClientEngineProvider
Constructors
TestReliableEngineProvider()
Declaration
public TestReliableEngineProvider()
Properties
Provider
Declaration
public IQueryProvider Provider { get; }
Property Value
| Type |
Description |
| System.Linq.IQueryProvider |
|
Methods
AcknowledgeRange(Uri, Int64)
Declaration
public void AcknowledgeRange(Uri subscriptionUri, long sequenceId)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
| System.Int64 |
sequenceId |
|
AssertCreateObserver(Uri)
Declaration
public virtual void AssertCreateObserver(Uri streamUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamUri |
|
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 |
|
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
AssertOnStarted(Uri)
Declaration
protected virtual void AssertOnStarted(Uri observerUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
observerUri |
|
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 |
|
CreateObserver(Uri)
Declaration
public void CreateObserver(Uri streamUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamUri |
|
CreateStream(Uri, Expression, Object)
Declaration
public void CreateStream(Uri streamUri, Expression stream, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamUri |
|
| System.Linq.Expressions.Expression |
stream |
|
| System.Object |
state |
|
CreateSubscription(Uri, Expression, Object)
Declaration
public void CreateSubscription(Uri subscriptionUri, Expression subscription, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
| System.Linq.Expressions.Expression |
subscription |
|
| System.Object |
state |
|
DefineObservable(Uri, Expression, Object)
Declaration
public void DefineObservable(Uri observableUri, Expression observable, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
observableUri |
|
| System.Linq.Expressions.Expression |
observable |
|
| System.Object |
state |
|
DefineObserver(Uri, Expression, Object)
Declaration
public void DefineObserver(Uri observerUri, Expression observer, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
observerUri |
|
| System.Linq.Expressions.Expression |
observer |
|
| System.Object |
state |
|
DefineStreamFactory(Uri, Expression, Object)
Declaration
public void DefineStreamFactory(Uri streamFactoryUri, Expression streamFactory, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamFactoryUri |
|
| System.Linq.Expressions.Expression |
streamFactory |
|
| System.Object |
state |
|
DefineSubscriptionFactory(Uri, Expression, Object)
Declaration
public void DefineSubscriptionFactory(Uri subscriptionFactoryUri, Expression subscriptionFactory, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionFactoryUri |
|
| System.Linq.Expressions.Expression |
subscriptionFactory |
|
| System.Object |
state |
|
DeleteStream(Uri)
Declaration
public void DeleteStream(Uri streamUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamUri |
|
DeleteSubscription(Uri)
Declaration
public void DeleteSubscription(Uri subscriptionUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
GetObserver<T>(Uri)
Declaration
public IReliableReactiveObserver<T> GetObserver<T>(Uri observerUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
observerUri |
|
Returns
Type Parameters
GetSubscriptionResubscribeUri(Uri)
Declaration
public Uri GetSubscriptionResubscribeUri(Uri subscriptionUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
Returns
| Type |
Description |
| System.Uri |
|
StartSubscription(Uri, Int64)
Declaration
public void StartSubscription(Uri subscriptionUri, long sequenceId)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
| System.Int64 |
sequenceId |
|
UndefineObservable(Uri)
Declaration
public void UndefineObservable(Uri observableUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
observableUri |
|
UndefineObserver(Uri)
Declaration
public void UndefineObserver(Uri observerUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
observerUri |
|
UndefineStreamFactory(Uri)
Declaration
public void UndefineStreamFactory(Uri streamFactoryUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamFactoryUri |
|
UndefineSubscriptionFactory(Uri)
Declaration
public void UndefineSubscriptionFactory(Uri subscriptionFactoryUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionFactoryUri |
|
Implements