Show / Hide Table of Contents

Class ReliableQubscription

Inheritance
System.Object
ReliableReactiveSubscriptionBase
ReliableQubscriptionBase
ReliableQubscription
KnownReliableQubscription
Implements
IReliableQubscription
IReliableReactiveSubscription
IReliableSubscription
ISubscription
System.IDisposable
IReliableReactiveExpressible
IExpressible
Inherited Members
ReliableQubscriptionBase.Provider
ReliableReactiveSubscriptionBase.Start(Int64)
ReliableReactiveSubscriptionBase.AcknowledgeRange(Int64)
ReliableReactiveSubscriptionBase.Dispose()
ReliableReactiveSubscriptionBase.Dispose(Boolean)
Namespace: Reaqtor.Reliable.Service
Assembly: Reaqtor.Reliable.dll
Syntax
public class ReliableQubscription : ReliableQubscriptionBase, IReliableQubscription, IReliableReactiveSubscription, IReliableSubscription, ISubscription, IDisposable, IReliableReactiveExpressible, IExpressible

Constructors

ReliableQubscription(Expression, IReliableQueryProvider)

Declaration
public ReliableQubscription(Expression expression, IReliableQueryProvider provider)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression
IReliableQueryProvider provider

Properties

Expression

Declaration
public override Expression Expression { get; }
Property Value
Type Description
System.Linq.Expressions.Expression
Overrides
ReliableQubscriptionBase.Expression

ResubscribeUri

Declaration
public override Uri ResubscribeUri { get; }
Property Value
Type Description
System.Uri
Overrides
ReliableReactiveSubscriptionBase.ResubscribeUri

Methods

Accept(ISubscriptionVisitor)

Declaration
public override void Accept(ISubscriptionVisitor visitor)
Parameters
Type Name Description
ISubscriptionVisitor visitor
Overrides
ReliableReactiveSubscriptionBase.Accept(ISubscriptionVisitor)

AcknowledgeRangeCore(Int64)

Declaration
protected override void AcknowledgeRangeCore(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId
Overrides
ReliableReactiveSubscriptionBase.AcknowledgeRangeCore(Int64)

DisposeCore()

Declaration
protected override void DisposeCore()
Overrides
ReliableReactiveSubscriptionBase.DisposeCore()

StartCore(Int64)

Declaration
protected override void StartCore(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId
Overrides
ReliableReactiveSubscriptionBase.StartCore(Int64)

Implements

IReliableQubscription
IReliableReactiveSubscription
IReliableSubscription
ISubscription
System.IDisposable
IReliableReactiveExpressible
IExpressible
In This Article
Back to top Generated by DocFX