Class ReactiveQueryProvider

Reactive processing query provider using a data operations object to perform service-side operations.

Inheritance

System.Object

ReactiveQueryProviderBase

ReactiveQueryProvider

Implements

IReactiveQueryProvider

Inherited Members

ReactiveQueryProviderBase.CreateQbservable<T>(Expression)

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

ReactiveQueryProviderBase.CreateQbserver<T>(Expression)

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

ReactiveQueryProviderBase.CreateQubjectFactory<TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArgs, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubject<TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubscription(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArgs>(Expression)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TResult>(Expression<Func<TArg1, TArg2, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TResult>(Expression<Func<TArg1, TArg2, TArg3, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, IReactiveQbservable<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TResult>(Expression<Func<TArg1, TArg2, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TResult>(Expression<Func<TArg1, TArg2, TArg3, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQbserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, IReactiveQbserver<TResult>>>)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubjectFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TInput, TOutput>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>(Expression)

ReactiveQueryProviderBase.CreateQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>(Expression)

ReactiveQueryProviderBase.ExpressionServices

Namespace: Reaqtor

Assembly: Reaqtor.Service.dll

Syntax

public class ReactiveQueryProvider : ReactiveQueryProviderBase, IReactiveQueryProvider

Constructors

ReactiveQueryProvider(IReactiveClientEngineProvider, IReactiveExpressionServices)

Creates a new reactive processing query provider using the specified data operations object.

Declaration

public ReactiveQueryProvider(IReactiveClientEngineProvider provider, IReactiveExpressionServices expressionServices)

Parameters

Type	Name	Description
IReactiveClientEngineProvider	provider	Data operations object to delegate operations to.
IReactiveExpressionServices	expressionServices	Expression services object, used to perform expression tree manipulations.

Methods

CreateStreamCore<TInput, TOutput>(IReactiveQubject<TInput, TOutput>, Object)

Creates a stream.

Declaration

protected override void CreateStreamCore<TInput, TOutput>(IReactiveQubject<TInput, TOutput> stream, object state)

Parameters

Type	Name	Description
IReactiveQubject<TInput, TOutput>	stream	Stream to create.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

Type Parameters

Name	Description
TInput	Type of the data received by the subject.
TOutput	Type of the data produced by the subject.

Overrides

Reaqtor.ReactiveQueryProviderBase.CreateStreamCore<TInput, TOutput>(Reaqtor.IReactiveQubject<TInput, TOutput>, System.Object)

CreateSubscriptionCore(IReactiveQubscription, Object)

Creates a subscription.

Declaration

protected override void CreateSubscriptionCore(IReactiveQubscription subscription, object state)

Parameters

Type	Name	Description
IReactiveQubscription	subscription	Subscription to create.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

Overrides

ReactiveQueryProviderBase.CreateSubscriptionCore(IReactiveQubscription, Object)

DeleteStreamCore<TInput, TOutput>(IReactiveQubject<TInput, TOutput>)

Deletes a stream.

Declaration

protected override void DeleteStreamCore<TInput, TOutput>(IReactiveQubject<TInput, TOutput> stream)

Parameters

Type	Name	Description
IReactiveQubject<TInput, TOutput>	stream	Stream to delete.

Type Parameters

Name	Description
TInput	Type of the data received by the subject.
TOutput	Type of the data produced by the subject.

Overrides

Reaqtor.ReactiveQueryProviderBase.DeleteStreamCore<TInput, TOutput>(Reaqtor.IReactiveQubject<TInput, TOutput>)

DeleteSubscriptionCore(IReactiveQubscription)

Deletes a subscription.

Declaration

protected override void DeleteSubscriptionCore(IReactiveQubscription subscription)

Parameters

Type	Name	Description
IReactiveQubscription	subscription	Subscription to delete.

Overrides

ReactiveQueryProviderBase.DeleteSubscriptionCore(IReactiveQubscription)

GetObserverCore<T>(IReactiveQbserver<T>)

Gets an observer to send notifications to.

Declaration

protected override IReactiveObserver<T> GetObserverCore<T>(IReactiveQbserver<T> observer)

Parameters

Type	Name	Description
IReactiveQbserver<T>	observer	Expression tree representation of an observer to get a publication observer for.

Returns

Type	Description
IReactiveObserver<T>	Observer to send notifications to.

Type Parameters

Name	Description
T

Overrides

Reaqtor.ReactiveQueryProviderBase.GetObserverCore<T>(Reaqtor.IReactiveQbserver<T>)

Implements

IReactiveQueryProvider