Class AsyncReactiveQbservableBase<T>

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

Inheritance
System.Object
AsyncReactiveObservableBase<T>
AsyncReactiveQbservableBase<T>
Inherited Members
Namespace: Reaqtor
Assembly: Reaqtor.Expressions.Core.dll
Syntax
public abstract class AsyncReactiveQbservableBase<T> : AsyncReactiveObservableBase<T>, IAsyncReactiveQbservable<T>, IAsyncReactiveObservable<T>, IAsyncReactiveQbservable, IAsyncReactiveExpressible, IExpressible
Type Parameters
Name Description
T

Type of the data produced by the observable.

Constructors

AsyncReactiveQbservableBase(IAsyncReactiveQueryProvider)

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

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

Query provider associated with the observable.

Properties

ElementType

Gets the type of the data produced by the observable.

Declaration
public Type ElementType { get; }
Property Value
Type Description
System.Type

Expression

Gets the expression tree representing the observable.

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

Provider

Gets the query provider that is associated with the observable.

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

Methods

SubscribeAsync(IAsyncReactiveQbserver<T>, Uri, Object, CancellationToken)

Subscribes to the observable using the given observer.

Declaration
public Task<IAsyncReactiveQubscription> SubscribeAsync(IAsyncReactiveQbserver<T> observer, Uri subscriptionUri, object state = null, CancellationToken token = null)
Parameters
Type Name Description
IAsyncReactiveQbserver<T> observer

Observer to send the observable's data to.
System.Uri subscriptionUri

URI to identify 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 that can be used to cancel the subscription, or an exception if the submission was unsuccessful.

SubscribeAsyncCore(IAsyncReactiveObserver<T>, Uri, Object, CancellationToken)

Subscribes to the observable using the given observer.

Declaration
protected override Task<IAsyncReactiveSubscription> SubscribeAsyncCore(IAsyncReactiveObserver<T> observer, Uri subscriptionUri, object state, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveObserver<T> observer

Observer to send the observable's data to.
System.Uri subscriptionUri

URI to identify 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 that can be used to cancel the subscription, or an exception if the submission was unsuccessful.
Overrides
Reaqtor.AsyncReactiveObservableBase<T>.SubscribeAsyncCore(Reaqtor.IAsyncReactiveObserver<T>, System.Uri, System.Object, System.Threading.CancellationToken)

SubscribeAsyncCore(IAsyncReactiveQbserver<T>, Uri, Object, CancellationToken)

Subscribes to the observable using the given observer.

Declaration
protected abstract Task<IAsyncReactiveQubscription> SubscribeAsyncCore(IAsyncReactiveQbserver<T> observer, Uri subscriptionUri, object state, CancellationToken token)
Parameters
Type Name Description
IAsyncReactiveQbserver<T> observer

Observer to send the observable's data to.
System.Uri subscriptionUri

URI to identify 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 that can be used to cancel the subscription, or an exception if the submission was unsuccessful.

Implements