Show / Hide Table of Contents

Class AsyncReactiveQbserverBase<T>

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

Inheritance
System.Object
AsyncReactiveObserverBase<T>
AsyncReactiveQbserverBase<T>
Implements
IAsyncReactiveQbserver<T>
IAsyncReactiveObserver<T>
IAsyncReactiveQbserver
IAsyncReactiveExpressible
IExpressible
Inherited Members
AsyncReactiveObserverBase<T>.OnNextAsync(T, CancellationToken)
AsyncReactiveObserverBase<T>.OnNextAsyncCore(T, CancellationToken)
AsyncReactiveObserverBase<T>.OnErrorAsync(Exception, CancellationToken)
AsyncReactiveObserverBase<T>.OnErrorAsyncCore(Exception, CancellationToken)
AsyncReactiveObserverBase<T>.OnCompletedAsync(CancellationToken)
AsyncReactiveObserverBase<T>.OnCompletedAsyncCore(CancellationToken)
Namespace: Reaqtor
Assembly: Reaqtor.Expressions.Core.dll
Syntax
public abstract class AsyncReactiveQbserverBase<T> : AsyncReactiveObserverBase<T>, IAsyncReactiveQbserver<T>, IAsyncReactiveObserver<T>, IAsyncReactiveQbserver, IAsyncReactiveExpressible, IExpressible
Type Parameters
Name Description
T

Type of the data received by the observer.

Constructors

AsyncReactiveQbserverBase(IAsyncReactiveQueryProvider)

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

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

Query provider associated with the observer.

Properties

ElementType

Gets the type of the data received by the observer.

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

Expression

Gets the expression tree representing the observer.

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

Provider

Gets the query provider that is associated with the observer.

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

Implements

IAsyncReactiveQbserver<T>
IAsyncReactiveObserver<T>
IAsyncReactiveQbserver
IAsyncReactiveExpressible
IExpressible
In This Article
Back to top Generated by DocFX