Class ReactiveQueryProviderExtensions

Provides a set of static methods to work with query providers.

Inheritance

System.Object

ReactiveQueryProviderExtensions

Namespace: Reaqtor

Assembly: Reaqtor.Expressions.Core.dll

Syntax

public static class ReactiveQueryProviderExtensions : Object

Methods

CreateQbservable<T>(IReactiveQueryProvider, Expression<Func<IReactiveQbserver<T>, Uri, Object, CancellationToken, Task<IReactiveQubscription>>>)

Creates an observable from the specified observable's Subscribe(IReactiveQbserver<T>, Uri, Object) implementation method.

Declaration

public static IReactiveQbservable<T> CreateQbservable<T>(this IReactiveQueryProvider provider, Expression<Func<IReactiveQbserver<T>, Uri, object, CancellationToken, Task<IReactiveQubscription>>> subscribe)

Parameters

Type	Name	Description
IReactiveQueryProvider	provider	Provider to use for creation of the observable.
System.Linq.Expressions.Expression<System.Func<IReactiveQbserver<T>, System.Uri, System.Object, System.Threading.CancellationToken, System.Threading.Tasks.Task<IReactiveQubscription>>>	subscribe	The observable's Subscribe(IReactiveQbserver<T>, Uri, Object) method implementation.

Returns

Type	Description
IReactiveQbservable<T>	Newly created observable. To define the observable on a service, use IReactiveDefinition.DefineObservable.

Type Parameters

Name	Description
T	Type of the data produced by the observable.

CreateQubjectFactory<TInput, TOutput>(IReactiveQueryProvider, Expression<Func<Uri, Object, CancellationToken, Task<IReactiveQubject<TInput, TOutput>>>>)

Creates a subject factory from the specified factory's Create(Uri, Object) implementation method.

Declaration

public static IReactiveQubjectFactory<TInput, TOutput> CreateQubjectFactory<TInput, TOutput>(this IReactiveQueryProvider provider, Expression<Func<Uri, object, CancellationToken, Task<IReactiveQubject<TInput, TOutput>>>> create)

Parameters

Type	Name	Description
IReactiveQueryProvider	provider	Provider to use for creation of the factory.
System.Linq.Expressions.Expression<System.Func<System.Uri, System.Object, System.Threading.CancellationToken, System.Threading.Tasks.Task<IReactiveQubject<TInput, TOutput>>>>	create	The factory's Create(Uri, Object) method implementation.

Returns

Type	Description
IReactiveQubjectFactory<TInput, TOutput>	Newly created stream factory. To define the factory on a service, use IReactiveDefinition.DefineStreamFactory.

Type Parameters

Name	Description
TInput	Type of the data received by the subjects created by the stream factory.
TOutput	Type of the data produced by the subjects created by the stream factory.

CreateQubjectFactory<TArgs, TInput, TOutput>(IReactiveQueryProvider, Expression<Func<Uri, TArgs, Object, CancellationToken, Task<IReactiveQubject<TInput, TOutput>>>>)

Creates a parameterized subject factory from the specified factory's Create(Uri, TArgs, Object) implementation method.

Declaration

public static IReactiveQubjectFactory<TInput, TOutput, TArgs> CreateQubjectFactory<TArgs, TInput, TOutput>(this IReactiveQueryProvider provider, Expression<Func<Uri, TArgs, object, CancellationToken, Task<IReactiveQubject<TInput, TOutput>>>> create)

Parameters

Type	Name	Description
IReactiveQueryProvider	provider	Provider to use for creation of the factory.
System.Linq.Expressions.Expression<System.Func<System.Uri, TArgs, System.Object, System.Threading.CancellationToken, System.Threading.Tasks.Task<IReactiveQubject<TInput, TOutput>>>>	create	The factory's Create(Uri, TArgs, Object) method implementation.

Returns

Type	Description
IReactiveQubjectFactory<TInput, TOutput, TArgs>	Newly created parameterized stream factory. To define the factory on a service, use IReactiveDefinition.DefineStreamFactory.

Type Parameters

Name	Description
TArgs	Type of the parameter passed to the subject factory.
TInput	Type of the data received by the subjects created by the stream factory.
TOutput	Type of the data produced by the subjects created by the stream factory.