Class AsyncReactiveQubscriptionFactoryBase

Base class for the implementation of subscription factories represented by an expression tree.

Inheritance
System.Object
AsyncReactiveQubscriptionFactoryBase
Namespace: Reaqtor
Assembly: Reaqtor.Expressions.Core.dll
Syntax
public abstract class AsyncReactiveQubscriptionFactoryBase : Object, IAsyncReactiveQubscriptionFactory, IAsyncReactiveSubscriptionFactory, IAsyncReactiveExpressible, IExpressible

Constructors

AsyncReactiveQubscriptionFactoryBase(IAsyncReactiveQueryProvider)

Creates a new subscription factory represented by an expression tree, using the specified associated query provider.

Declaration
protected AsyncReactiveQubscriptionFactoryBase(IAsyncReactiveQueryProvider provider)
Parameters
Type Name Description
IAsyncReactiveQueryProvider provider

Query provider associated with the subscription factory.

Properties

Expression

Gets the expression tree representing the subscription factory.

Declaration
public abstract Expression Expression { get; }
Property Value
Type Description
System.Linq.Expressions.Expression

Provider

Gets the query provider that is associated with the subscription factory.

Declaration
public IAsyncReactiveQueryProvider Provider { get; }
Property Value
Type Description
IAsyncReactiveQueryProvider

Methods

CreateAsync(Uri, Object, CancellationToken)

Creates a new subscription with the specified subscription URI.

Declaration
public Task<IAsyncReactiveQubscription> CreateAsync(Uri subscriptionUri, object state = null, CancellationToken token = null)
Parameters
Type Name Description
System.Uri subscriptionUri

URI identifying the subscription.
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<IAsyncReactiveQubscription>

Task returning a subscription object, or an exception if the creation request was unsuccessful.

CreateAsyncCore(Uri, Object, CancellationToken)

Creates a new subscription with the specified subscription URI.

Declaration
protected abstract Task<IAsyncReactiveQubscription> CreateAsyncCore(Uri subscriptionUri, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri subscriptionUri

URI identifying the subscription.
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<IAsyncReactiveQubscription>

Task returning a subscription object, or an exception if the creation request was unsuccessful.

Explicit Interface Implementations

IAsyncReactiveSubscriptionFactory.CreateAsync(Uri, Object, CancellationToken)

Creates a new subscription with the specified subscription URI.

Declaration
Task<IAsyncReactiveSubscription> IAsyncReactiveSubscriptionFactory.CreateAsync(Uri subscriptionUri, object state, CancellationToken token)
Parameters
Type Name Description
System.Uri subscriptionUri

URI identifying the subscription.
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<IAsyncReactiveSubscription>

Task returning a subscription object, or an exception if the creation request was unsuccessful.

Implements