Interface IReactiveQueryProvider

Interface for reactive processing query providers, used to build observables, observers, subjects, and subscriptions represented by expression trees.

Namespace: Reaqtor
Assembly: Reaqtor.Expressions.Model.dll
Syntax
public interface IReactiveQueryProvider

Methods

CreateQbservable<T>(Expression)

Creates an observable based on the given expression.

Declaration
IReactiveQbservable<T> CreateQbservable<T>(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the observable.
Returns
Type Description
IReactiveQbservable<T>

Observable represented by the given expression.
Type Parameters
Name Description
T

Type of the data produced by the observable.

CreateQbservable<TArgs, TResult>(Expression<Func<TArgs, IReactiveQbservable<TResult>>>)

Creates a parameterized observable based on the given expression.

Declaration
Func<TArgs, IReactiveQbservable<TResult>> CreateQbservable<TArgs, TResult>(Expression<Func<TArgs, IReactiveQbservable<TResult>>> expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression<System.Func<TArgs, IReactiveQbservable<TResult>>> expression

Expression representing the observable.
Returns
Type Description
System.Func<TArgs, IReactiveQbservable<TResult>>

Parameterized observable represented by the given expression.
Type Parameters
Name Description
TArgs

Type of the parameter passed to the observable.
TResult

Type of the data produced by the observable.

CreateQbserver<T>(Expression)

Creates an observer based on the given expression.

Declaration
IReactiveQbserver<T> CreateQbserver<T>(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the observer.
Returns
Type Description
IReactiveQbserver<T>

Observer represented by the given expression.
Type Parameters
Name Description
T

Type of the data received by the observer.

CreateQbserver<TArgs, TResult>(Expression<Func<TArgs, IReactiveQbserver<TResult>>>)

Creates a parameterized observer based on the given expression.

Declaration
Func<TArgs, IReactiveQbserver<TResult>> CreateQbserver<TArgs, TResult>(Expression<Func<TArgs, IReactiveQbserver<TResult>>> expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression<System.Func<TArgs, IReactiveQbserver<TResult>>> expression

Expression representing the observer.
Returns
Type Description
System.Func<TArgs, IReactiveQbserver<TResult>>

Parameterized observer represented by the given expression.
Type Parameters
Name Description
TArgs

Type of the parameter passed to the observer.
TResult

Type of the data received by the observer.

CreateQubject<TInput, TOutput>(Expression)

Creates a subject based on the given expression.

Declaration
IReactiveQubject<TInput, TOutput> CreateQubject<TInput, TOutput>(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the subject.
Returns
Type Description
IReactiveQubject<TInput, TOutput>

Subject represented by the given expression.
Type Parameters
Name Description
TInput

Type of the data received by the subject.
TOutput

Type of the data produced by the subject.

CreateQubjectFactory<TInput, TOutput>(Expression)

Creates a subject factory based on the given expression.

Declaration
IReactiveQubjectFactory<TInput, TOutput> CreateQubjectFactory<TInput, TOutput>(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the subject factory.
Returns
Type Description
IReactiveQubjectFactory<TInput, TOutput>

Subject factory represented by the given expression.
Type Parameters
Name Description
TInput

Type of the data received by the subject created by the factory.
TOutput

Type of the data produced by the subject created by the factory.

CreateQubjectFactory<TArgs, TInput, TOutput>(Expression)

Creates a parameterized subject factory based on the given expression.

Declaration
IReactiveQubjectFactory<TInput, TOutput, TArgs> CreateQubjectFactory<TArgs, TInput, TOutput>(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the subject factory.
Returns
Type Description
IReactiveQubjectFactory<TInput, TOutput, TArgs>

Parameterized subject factory represented by the given expression.
Type Parameters
Name Description
TArgs

Type of the parameter passed to the subject factory.
TInput

Type of the data received by the subject created by the factory.
TOutput

Type of the data produced by the subject created by the factory.

CreateQubscription(Expression)

Creates a subscription based on the given expression.

Declaration
IReactiveQubscription CreateQubscription(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the subscription.
Returns
Type Description
IReactiveQubscription

Subscription represented by the given expression.

CreateQubscriptionFactory(Expression)

Creates a subscription factory based on the given expression.

Declaration
IReactiveQubscriptionFactory CreateQubscriptionFactory(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the subscription factory.
Returns
Type Description
IReactiveQubscriptionFactory

Subscription factory represented by the given expression.

CreateQubscriptionFactory<TArgs>(Expression)

Creates a parameterized subscription factory based on the given expression.

Declaration
IReactiveQubscriptionFactory<TArgs> CreateQubscriptionFactory<TArgs>(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression

Expression representing the subscription factory.
Returns
Type Description
IReactiveQubscriptionFactory<TArgs>

Parameterized subscription factory represented by the given expression.
Type Parameters
Name Description
TArgs

Type of the parameter passed to the subscription factory.

Extension Methods