Class ReliableQueryProvider

Inheritance

System.Object

ReliableQueryProviderBase

ReliableQueryProvider

Implements

IReliableQueryProvider

Inherited Members

ReliableQueryProviderBase.CreateQbservable<T>(Expression)

ReliableQueryProviderBase.CreateQbservable<TArgs, TResult>(Expression<Func<TArgs, IReliableQbservable<TResult>>>)

ReliableQueryProviderBase.CreateQbserver<T>(Expression)

ReliableQueryProviderBase.CreateQbserver<TArgs, TResult>(Expression<Func<TArgs, IReliableQbserver<TResult>>>)

ReliableQueryProviderBase.CreateQubjectFactory<TInput, TOutput>(Expression)

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

ReliableQueryProviderBase.CreateQubject<TInput, TOutput>(Expression)

ReliableQueryProviderBase.CreateQubscriptionFactory(Expression)

ReliableQueryProviderBase.CreateQubscriptionFactory<TArgs>(Expression)

ReliableQueryProviderBase.CreateQubscription(Expression)

Namespace: Reaqtor.Reliable.Service

Assembly: Reaqtor.Reliable.dll

Syntax

public class ReliableQueryProvider : ReliableQueryProviderBase, IReliableQueryProvider

Constructors

ReliableQueryProvider(IReliableReactiveClientEngineProvider, IReactiveExpressionServices)

Declaration

public ReliableQueryProvider(IReliableReactiveClientEngineProvider provider, IReactiveExpressionServices expressionServices)

Parameters

Type	Name	Description
IReliableReactiveClientEngineProvider	provider
IReactiveExpressionServices	expressionServices

Methods

AcknowledgeRangeCore(IReliableQubscription, Int64)

Declaration

protected override void AcknowledgeRangeCore(IReliableQubscription subscription, long sequenceId)

Parameters

Type	Name	Description
IReliableQubscription	subscription
System.Int64	sequenceId

Overrides

ReliableQueryProviderBase.AcknowledgeRangeCore(IReliableQubscription, Int64)

CreateObserverCore<TInput, TOutput>(IReliableMultiQubject<TInput, TOutput>)

Declaration

protected override IReliableQbserver<TInput> CreateObserverCore<TInput, TOutput>(IReliableMultiQubject<TInput, TOutput> stream)

Parameters

Type	Name	Description
IReliableMultiQubject<TInput, TOutput>	stream

Returns

Type	Description
IReliableQbserver<TInput>

Type Parameters

Name	Description
TInput
TOutput

Overrides

Reaqtor.Reliable.Service.ReliableQueryProviderBase.CreateObserverCore<TInput, TOutput>(Reaqtor.Reliable.Expressions.IReliableMultiQubject<TInput, TOutput>)

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

Declaration

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

Parameters

Type	Name	Description
IReliableMultiQubject<TInput, TOutput>	stream
System.Object	state

Type Parameters

Name	Description
TInput
TOutput

Overrides

Reaqtor.Reliable.Service.ReliableQueryProviderBase.CreateStreamCore<TInput, TOutput>(Reaqtor.Reliable.Expressions.IReliableMultiQubject<TInput, TOutput>, System.Object)

CreateSubscriptionCore(IReliableQubscription, Object)

Declaration

protected override void CreateSubscriptionCore(IReliableQubscription subscription, object state)

Parameters

Type	Name	Description
IReliableQubscription	subscription
System.Object	state

Overrides

ReliableQueryProviderBase.CreateSubscriptionCore(IReliableQubscription, Object)

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

Declaration

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

Parameters

Type	Name	Description
IReliableMultiQubject<TInput, TOutput>	stream

Type Parameters

Name	Description
TInput
TOutput

Overrides

Reaqtor.Reliable.Service.ReliableQueryProviderBase.DeleteStreamCore<TInput, TOutput>(Reaqtor.Reliable.Expressions.IReliableMultiQubject<TInput, TOutput>)

DeleteSubscriptionCore(IReliableQubscription)

Declaration

protected override void DeleteSubscriptionCore(IReliableQubscription subscription)

Parameters

Type	Name	Description
IReliableQubscription	subscription

Overrides

ReliableQueryProviderBase.DeleteSubscriptionCore(IReliableQubscription)

GetObserverCore<T>(IReliableQbserver<T>)

Declaration

protected override IReliableReactiveObserver<T> GetObserverCore<T>(IReliableQbserver<T> observer)

Parameters

Type	Name	Description
IReliableQbserver<T>	observer

Returns

Type	Description
IReliableReactiveObserver<T>

Type Parameters

Name	Description
T

Overrides

Reaqtor.Reliable.Service.ReliableQueryProviderBase.GetObserverCore<T>(Reaqtor.Reliable.Expressions.IReliableQbserver<T>)

GetSubscriptionResubscribeUriCore(IReliableQubscription)

Declaration

protected override Uri GetSubscriptionResubscribeUriCore(IReliableQubscription subscription)

Parameters

Type	Name	Description
IReliableQubscription	subscription

Returns

Type	Description
System.Uri

Overrides

ReliableQueryProviderBase.GetSubscriptionResubscribeUriCore(IReliableQubscription)

StartSubscriptionCore(IReliableQubscription, Int64)

Declaration

protected override void StartSubscriptionCore(IReliableQubscription subscription, long sequenceId)

Parameters

Type	Name	Description
IReliableQubscription	subscription
System.Int64	sequenceId

Overrides

ReliableQueryProviderBase.StartSubscriptionCore(IReliableQubscription, Int64)

Implements

IReliableQueryProvider