Class AsyncReactiveQubscriptionFactoryBase<TArgs>

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

Inheritance
System.Object
AsyncReactiveQubscriptionFactoryBase<TArgs>
Namespace: Reaqtor
Assembly: Reaqtor.Expressions.Core.dll
Syntax
public abstract class AsyncReactiveQubscriptionFactoryBase<TArgs> : Object, IAsyncReactiveQubscriptionFactory<TArgs>, IAsyncReactiveSubscriptionFactory<TArgs>, IAsyncReactiveExpressible, IExpressible
Type Parameters
Name Description
TArgs

Type of the parameter passed to the subscription factory.

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, TArgs, Object, CancellationToken)

Creates a new subscription with the specified subscription URI.

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

URI identifying the subscription.
TArgs argument

Parameter to pass to the subscription 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<IAsyncReactiveQubscription>

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

CreateAsyncCore(Uri, TArgs, Object, CancellationToken)

Creates a new subscription with the specified subscription URI.

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

URI identifying the subscription.
TArgs argument

Parameter to pass to the subscription 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<IAsyncReactiveQubscription>

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

Explicit Interface Implementations

IAsyncReactiveSubscriptionFactory<TArgs>.CreateAsync(Uri, TArgs, Object, CancellationToken)

Creates a new subscription with the specified subscription URI.

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

URI identifying the subscription.
TArgs argument

Parameter to pass to the subscription 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<IAsyncReactiveSubscription>

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

Implements