Interface IReliableReactiveClientEngineProvider
Assembly: Reaqtor.Reliable.Model.dll
Syntax
public interface IReliableReactiveClientEngineProvider
Methods
AcknowledgeRange(Uri, Int64)
Declaration
void AcknowledgeRange(Uri subscriptionUri, long sequenceId)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
| System.Int64 |
sequenceId |
|
CreateObserver(Uri)
Declaration
void CreateObserver(Uri streamUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamUri |
|
CreateStream(Uri, Expression, Object)
Declaration
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
void CreateSubscription(Uri subscriptionUri, Expression subscription, object state)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
| System.Linq.Expressions.Expression |
subscription |
|
| System.Object |
state |
|
DeleteStream(Uri)
Declaration
void DeleteStream(Uri streamUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
streamUri |
|
DeleteSubscription(Uri)
Declaration
void DeleteSubscription(Uri subscriptionUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
GetObserver<T>(Uri)
Declaration
IReliableReactiveObserver<T> GetObserver<T>(Uri observerUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
observerUri |
|
Returns
Type Parameters
GetSubscriptionResubscribeUri(Uri)
Declaration
Uri GetSubscriptionResubscribeUri(Uri subscriptionUri)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
Returns
| Type |
Description |
| System.Uri |
|
StartSubscription(Uri, Int64)
Declaration
void StartSubscription(Uri subscriptionUri, long sequenceId)
Parameters
| Type |
Name |
Description |
| System.Uri |
subscriptionUri |
|
| System.Int64 |
sequenceId |
|