Class AsyncReactiveQueryProvider

Reactive processing query provider using a data operations object to perform service-side operations.

Inheritance
System.Object
AsyncReactiveQueryProviderBase
AsyncReactiveQueryProvider
Inherited Members
Namespace: Reaqtor
Assembly: Reaqtor.Client.dll
Syntax
public class AsyncReactiveQueryProvider : AsyncReactiveQueryProviderBase, IAsyncReactiveQueryProvider

Constructors

AsyncReactiveQueryProvider(IReactiveClientServiceProvider, IReactiveExpressionServices)

Creates a new reactive processing query provider using the specified data operations object.

Declaration
public AsyncReactiveQueryProvider(IReactiveClientServiceProvider provider, IReactiveExpressionServices expressionServices)
Parameters
Type Name Description
IReactiveClientServiceProvider provider

Data operations object to delegate operations to.
IReactiveExpressionServices expressionServices

Expression services object, used to perform expression tree manipulations.

Methods

CreateStreamAsyncCore<TInput, TOutput>(IAsyncReactiveQubject<TInput, TOutput>, Object, CancellationToken)

Creates a stream.

Declaration
protected override Task CreateStreamAsyncCore<TInput, TOutput>(IAsyncReactiveQubject<TInput, TOutput> stream, object state, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveQubject<TInput, TOutput> stream

Stream to create.
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.
Type Parameters
Name Description
TInput

Type of the data received by the subject.
TOutput

Type of the data produced by the subject.
Overrides
Reaqtor.AsyncReactiveQueryProviderBase.CreateStreamAsyncCore<TInput, TOutput>(Reaqtor.IAsyncReactiveQubject<TInput, TOutput>, System.Object, System.Threading.CancellationToken)

CreateSubscriptionAsyncCore(IAsyncReactiveQubscription, Object, CancellationToken)

Creates a subscription.

Declaration
protected override Task CreateSubscriptionAsyncCore(IAsyncReactiveQubscription subscription, object state, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveQubscription subscription

Subscription to create.
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.
Overrides

DeleteStreamAsyncCore<TInput, TOutput>(IAsyncReactiveQubject<TInput, TOutput>, CancellationToken)

Deletes a stream.

Declaration
protected override Task DeleteStreamAsyncCore<TInput, TOutput>(IAsyncReactiveQubject<TInput, TOutput> stream, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveQubject<TInput, TOutput> stream

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.
Type Parameters
Name Description
TInput

Type of the data received by the subject.
TOutput

Type of the data produced by the subject.
Overrides
Reaqtor.AsyncReactiveQueryProviderBase.DeleteStreamAsyncCore<TInput, TOutput>(Reaqtor.IAsyncReactiveQubject<TInput, TOutput>, System.Threading.CancellationToken)

DeleteSubscriptionAsyncCore(IAsyncReactiveQubscription, CancellationToken)

Deletes a subscription.

Declaration
protected override Task DeleteSubscriptionAsyncCore(IAsyncReactiveQubscription subscription, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveQubscription subscription

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.
Overrides

GetObserverAsyncCore<T>(IAsyncReactiveQbserver<T>, CancellationToken)

Gets an observer to send notifications to.

Declaration
protected override Task<IAsyncReactiveObserver<T>> GetObserverAsyncCore<T>(IAsyncReactiveQbserver<T> observer, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveQbserver<T> observer

Expression tree representation of an observer to get a publication observer for.
System.Threading.CancellationToken token

Token used to observe cancellation requests.
Returns
Type Description
System.Threading.Tasks.Task<IAsyncReactiveObserver<T>>

Observer to send notifications to.
Type Parameters
Name Description
T
Overrides
Reaqtor.AsyncReactiveQueryProviderBase.GetObserverAsyncCore<T>(Reaqtor.IAsyncReactiveQbserver<T>, System.Threading.CancellationToken)

Implements