Interface IAsyncReactiveQueryProvider

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 IAsyncReactiveQueryProvider

Methods

CreateQbservable<T>(Expression)

Creates an observable based on the given expression.

Declaration

IAsyncReactiveQbservable<T> CreateQbservable<T>(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the observable.

Returns

Type	Description
IAsyncReactiveQbservable<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, IAsyncReactiveQbservable<TResult>>>)

Creates a parameterized observable based on the given expression.

Declaration

Func<TArgs, IAsyncReactiveQbservable<TResult>> CreateQbservable<TArgs, TResult>(Expression<Func<TArgs, IAsyncReactiveQbservable<TResult>>> expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression<System.Func<TArgs, IAsyncReactiveQbservable<TResult>>>	expression	Expression representing the observable.

Returns

Type	Description
System.Func<TArgs, IAsyncReactiveQbservable<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

IAsyncReactiveQbserver<T> CreateQbserver<T>(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the observer.

Returns

Type	Description
IAsyncReactiveQbserver<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, IAsyncReactiveQbserver<TResult>>>)

Creates a parameterized observer based on the given expression.

Declaration

Func<TArgs, IAsyncReactiveQbserver<TResult>> CreateQbserver<TArgs, TResult>(Expression<Func<TArgs, IAsyncReactiveQbserver<TResult>>> expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression<System.Func<TArgs, IAsyncReactiveQbserver<TResult>>>	expression	Expression representing the observer.

Returns

Type	Description
System.Func<TArgs, IAsyncReactiveQbserver<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

IAsyncReactiveQubject<TInput, TOutput> CreateQubject<TInput, TOutput>(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the subject.

Returns

Type	Description
IAsyncReactiveQubject<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

IAsyncReactiveQubjectFactory<TInput, TOutput> CreateQubjectFactory<TInput, TOutput>(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the subject factory.

Returns

Type	Description
IAsyncReactiveQubjectFactory<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

IAsyncReactiveQubjectFactory<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
IAsyncReactiveQubjectFactory<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

IAsyncReactiveQubscription CreateQubscription(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the subscription.

Returns

Type	Description
IAsyncReactiveQubscription	Subscription represented by the given expression.

CreateQubscriptionFactory(Expression)

Creates a subscription factory based on the given expression.

Declaration

IAsyncReactiveQubscriptionFactory CreateQubscriptionFactory(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the subscription factory.

Returns

Type	Description
IAsyncReactiveQubscriptionFactory	Subscription factory represented by the given expression.

CreateQubscriptionFactory<TArgs>(Expression)

Creates a parameterized subscription factory based on the given expression.

Declaration

IAsyncReactiveQubscriptionFactory<TArgs> CreateQubscriptionFactory<TArgs>(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression representing the subscription factory.

Returns

Type	Description
IAsyncReactiveQubscriptionFactory<TArgs>	Parameterized subscription factory represented by the given expression.

Type Parameters

Name	Description
TArgs	Type of the parameter passed to the subscription factory.