Class ReliableQueryProviderBase

Inheritance
System.Object
ReliableQueryProviderBase
ReliableQueryProvider
Namespace: Reaqtor.Reliable.Service
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableQueryProviderBase : Object, IReliableQueryProvider

Constructors

ReliableQueryProviderBase(IReactiveExpressionServices)

Declaration
protected ReliableQueryProviderBase(IReactiveExpressionServices expressionServices)
Parameters
Type Name Description
IReactiveExpressionServices expressionServices

Methods

AcknowledgeRangeCore(IReliableQubscription, Int64)

Declaration
protected abstract void AcknowledgeRangeCore(IReliableQubscription subscription, long sequenceId)
Parameters
Type Name Description
IReliableQubscription subscription
System.Int64 sequenceId

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

Declaration
protected abstract 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

CreateQbservable<T>(Expression)

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

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

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

CreateQbserver<T>(Expression)

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

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

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

CreateQubject<TInput, TOutput>(Expression)

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

CreateQubjectFactory<TInput, TOutput>(Expression)

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

CreateQubjectFactory<TArgs, TInput, TOutput>(Expression)

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

CreateQubscription(Expression)

Declaration
public IReliableQubscription CreateQubscription(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression
Returns
Type Description
IReliableQubscription

CreateQubscriptionFactory(Expression)

Declaration
public IReliableQubscriptionFactory CreateQubscriptionFactory(Expression expression)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression
Returns
Type Description
IReliableQubscriptionFactory

CreateQubscriptionFactory<TArgs>(Expression)

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

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

Declaration
protected abstract 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

CreateSubscriptionCore(IReliableQubscription, Object)

Declaration
protected abstract void CreateSubscriptionCore(IReliableQubscription subscription, object state)
Parameters
Type Name Description
IReliableQubscription subscription
System.Object state

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

Declaration
protected abstract void DeleteStreamCore<TInput, TOutput>(IReliableMultiQubject<TInput, TOutput> stream)
Parameters
Type Name Description
IReliableMultiQubject<TInput, TOutput> stream
Type Parameters
Name Description
TInput
TOutput

DeleteSubscriptionCore(IReliableQubscription)

Declaration
protected abstract void DeleteSubscriptionCore(IReliableQubscription subscription)
Parameters
Type Name Description
IReliableQubscription subscription

GetObserverCore<T>(IReliableQbserver<T>)

Declaration
protected abstract IReliableReactiveObserver<T> GetObserverCore<T>(IReliableQbserver<T> observer)
Parameters
Type Name Description
IReliableQbserver<T> observer
Returns
Type Description
IReliableReactiveObserver<T>
Type Parameters
Name Description
T

GetSubscriptionResubscribeUriCore(IReliableQubscription)

Declaration
protected abstract Uri GetSubscriptionResubscribeUriCore(IReliableQubscription subscription)
Parameters
Type Name Description
IReliableQubscription subscription
Returns
Type Description
System.Uri

StartSubscriptionCore(IReliableQubscription, Int64)

Declaration
protected abstract void StartSubscriptionCore(IReliableQubscription subscription, long sequenceId)
Parameters
Type Name Description
IReliableQubscription subscription
System.Int64 sequenceId

Implements