Class ReactiveQbservableBase<T>

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

Inheritance
System.Object
ReactiveObservableBase<T>
ReactiveQbservableBase<T>
Inherited Members
Namespace: Reaqtor
Assembly: Reaqtor.Expressions.Core.dll
Syntax
public abstract class ReactiveQbservableBase<T> : ReactiveObservableBase<T>, IReactiveQbservable<T>, IReactiveObservable<T>, IReactiveQbservable, IReactiveExpressible, IExpressible
Type Parameters
Name Description
T

Type of the data produced by the observable.

Constructors

ReactiveQbservableBase(IReactiveQueryProvider)

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

Declaration
protected ReactiveQbservableBase(IReactiveQueryProvider provider)
Parameters
Type Name Description
IReactiveQueryProvider 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 IReactiveQueryProvider Provider { get; }
Property Value
Type Description
IReactiveQueryProvider

Methods

Subscribe(IReactiveQbserver<T>, Uri, Object)

Subscribes to the observable using the given observer.

Declaration
public IReactiveQubscription Subscribe(IReactiveQbserver<T> observer, Uri subscriptionUri, object state = null)
Parameters
Type Name Description
IReactiveQbserver<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.
Returns
Type Description
IReactiveQubscription

A subscription object that can be used to cancel the subscription, or an exception if the submission was unsuccessful.

SubscribeCore(IReactiveObserver<T>, Uri, Object)

Subscribes to the observable using the given observer.

Declaration
protected override IReactiveSubscription SubscribeCore(IReactiveObserver<T> observer, Uri subscriptionUri, object state)
Parameters
Type Name Description
IReactiveObserver<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.
Returns
Type Description
IReactiveSubscription

A subscription object that can be used to cancel the subscription, or an exception if the submission was unsuccessful.
Overrides
Reaqtor.ReactiveObservableBase<T>.SubscribeCore(Reaqtor.IReactiveObserver<T>, System.Uri, System.Object)

SubscribeCore(IReactiveQbserver<T>, Uri, Object)

Subscribes to the observable using the given observer.

Declaration
protected abstract IReactiveQubscription SubscribeCore(IReactiveQbserver<T> observer, Uri subscriptionUri, object state)
Parameters
Type Name Description
IReactiveQbserver<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.
Returns
Type Description
IReactiveQubscription

A subscription object that can be used to cancel the subscription, or an exception if the submission was unsuccessful.

Implements