Class ReliableMultiSubjectBase<T>.Subscription

Inheritance
System.Object
ReliableMultiSubjectBase<T>.Subscription
Implements
System.IDisposable
Namespace: Reaqtor.Reliable
Assembly: Reaqtor.Reliable.dll
Syntax
protected sealed class Subscription : Object, IReliableSubscription, ISubscription, IDisposable

Constructors

Subscription(ReliableMultiSubjectBase<T>, IReliableObserver<T>, Int64)

Declaration
public Subscription(ReliableMultiSubjectBase<T> parent, IReliableObserver<T> observer, long lastAck)
Parameters
Type Name Description
ReliableMultiSubjectBase<T> parent
IReliableObserver<T> observer
System.Int64 lastAck

Properties

LastAck

Declaration
public long LastAck { get; }
Property Value
Type Description
System.Int64

ResubscribeUri

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

Methods

Accept(ISubscriptionVisitor)

Declaration
public void Accept(ISubscriptionVisitor visitor)
Parameters
Type Name Description
ISubscriptionVisitor visitor

AcknowledgeRange(Int64)

Declaration
public void AcknowledgeRange(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId

Dispose()

Declaration
public void Dispose()

OnCompleted()

Declaration
public void OnCompleted()

OnError(Exception)

Declaration
public void OnError(Exception error)
Parameters
Type Name Description
System.Exception error

OnNext(T, Int64)

Declaration
public void OnNext(T item, long sequenceId)
Parameters
Type Name Description
T item
System.Int64 sequenceId

Start(Int64)

Declaration
public void Start(long sequenceId)
Parameters
Type Name Description
System.Int64 sequenceId

StartCompleted()

Declaration
public void StartCompleted()

Implements

System.IDisposable