Interface IReactiveClientServiceProvider<TExpression>
Interface for client operations of a reactive processing service.
Namespace: Reaqtor
Assembly: Reaqtor.Service.Contracts.dll
Syntax
public interface IReactiveClientServiceProvider<TExpression>Type Parameters
| Name | Description |
|---|---|
| TExpression | Type used for expression tree representation. |
Methods
CreateStreamAsync(Uri, TExpression, Object, CancellationToken)
Creates a new stream using the specified expression tree representation.
Declaration
Task CreateStreamAsync(Uri streamUri, TExpression stream, object state, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | streamUri | URI to identify the new stream. |
| TExpression | stream | Expression representing the stream creation. (E.g. an invocation of a known stream factory.) |
| System.Object | state | Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it. |
| System.Threading.CancellationToken | token | Token to observe for cancellation of the request. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to await the acknowledgement of the creation of the stream, or an exception. |
CreateSubscriptionAsync(Uri, TExpression, Object, CancellationToken)
Creates a new subscription using the specified expression tree representation.
Declaration
Task CreateSubscriptionAsync(Uri subscriptionUri, TExpression subscription, object state, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | subscriptionUri | URI to identify the new subscription. |
| TExpression | subscription | Expression representing the subscription creation. (E.g. an invocation of the subscription operation on an observable.) |
| System.Object | state | Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it. |
| System.Threading.CancellationToken | token | Token to observe for cancellation of the request. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to await the acknowledgement of the creation of the subscription, or an exception. |
DeleteStreamAsync(Uri, CancellationToken)
Deletes the stream identified by the specified URI.
Declaration
Task DeleteStreamAsync(Uri streamUri, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | streamUri | URI of the stream to delete. |
| System.Threading.CancellationToken | token | Token to observe for cancellation of the request. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to await the acknowledgement of the deletion of the stream, or an exception. |
DeleteSubscriptionAsync(Uri, CancellationToken)
Deletes the subscription identified by the specified URI.
Declaration
Task DeleteSubscriptionAsync(Uri subscriptionUri, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | subscriptionUri | URI of the subscription to delete. |
| System.Threading.CancellationToken | token | Token to observe for cancellation of the request. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task | Task to await the acknowledgement of the deletion of the subscription, or an exception. |
GetObserverAsync<T>(Uri, CancellationToken)
Gets an observer to send notifications to.
Declaration
Task<IAsyncReactiveObserver<T>> GetObserverAsync<T>(Uri observerUri, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | observerUri | URI of the observer to send the notification to. |
| System.Threading.CancellationToken | token | Token used to observe cancellation requests. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task<IAsyncReactiveObserver<T>> | Observer that can be used to send notifcations to. |
Type Parameters
| Name | Description |
|---|---|
| T | Type of the value to send to the observer. |