Class ReliableMultiSubjectBase<T>

Inheritance
System.Object
ReliableMultiSubjectBase<T>
ReliableMultiSubject<T>
Namespace: Reaqtor.Reliable
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableMultiSubjectBase<T> : Object, IReliableMultiSubject<T>, IReliableMultiSubject<T, T>, IReliableMultiSubject, IDisposable, IReliableObservable<T>
Type Parameters
Name Description
T

Constructors

ReliableMultiSubjectBase()

Declaration
protected ReliableMultiSubjectBase()

Properties

Id

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

ItemCount

Declaration
protected int ItemCount { get; }
Property Value
Type Description
System.Int32

LowWatermark

Declaration
protected long LowWatermark { get; set; }
Property Value
Type Description
System.Int64

StateChanged

Declaration
public bool StateChanged { get; }
Property Value
Type Description
System.Boolean

SubscriptionCount

Declaration
protected int SubscriptionCount { get; }
Property Value
Type Description
System.Int32

Methods

CreateNewSubscription(IReliableObserver<T>)

Declaration
protected virtual ReliableMultiSubjectBase<T>.Subscription CreateNewSubscription(IReliableObserver<T> observer)
Parameters
Type Name Description
IReliableObserver<T> observer
Returns
Type Description
ReliableMultiSubjectBase.Subscription<>

CreateObserver()

Declaration
public IReliableObserver<T> CreateObserver()
Returns
Type Description
IReliableObserver<T>

Dispose()

Declaration
public void Dispose()

Dispose(Boolean)

Declaration
protected virtual void Dispose(bool disposing)
Parameters
Type Name Description
System.Boolean disposing

DisposeCore()

Declaration
protected abstract void DisposeCore()

DropAllSubscriptions()

Declaration
protected void DropAllSubscriptions()

LoadState(IOperatorStateReader, Version)

Declaration
public virtual void LoadState(IOperatorStateReader reader, Version version)
Parameters
Type Name Description
IOperatorStateReader reader
System.Version version

NotifySubscriptions(Int32)

Declaration
protected void NotifySubscriptions(int batchSize = 0)
Parameters
Type Name Description
System.Int32 batchSize

OnCompleted()

Declaration
protected virtual void OnCompleted()

OnError(Exception)

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

OnNext(T, Int64)

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

OnStateSaved()

Declaration
public virtual void OnStateSaved()

SaveState(IOperatorStateWriter, Version)

Declaration
public virtual void SaveState(IOperatorStateWriter writer, Version version)
Parameters
Type Name Description
IOperatorStateWriter writer
System.Version version

ShouldBufferedEventsBeDropped()

Declaration
protected virtual bool ShouldBufferedEventsBeDropped()
Returns
Type Description
System.Boolean

Start()

Declaration
public virtual void Start()

Subscribe(IReliableObserver<T>)

Declaration
public IReliableSubscription Subscribe(IReliableObserver<T> observer)
Parameters
Type Name Description
IReliableObserver<T> observer
Returns
Type Description
IReliableSubscription

SubscriptionAcknowledgeRange(Int64, ReliableMultiSubjectBase<T>.Subscription)

Declaration
protected virtual void SubscriptionAcknowledgeRange(long sequenceId, ReliableMultiSubjectBase<T>.Subscription subscription)
Parameters
Type Name Description
System.Int64 sequenceId
ReliableMultiSubjectBase.Subscription<> subscription

SubscriptionDispose(ReliableMultiSubjectBase<T>.Subscription)

Declaration
protected virtual void SubscriptionDispose(ReliableMultiSubjectBase<T>.Subscription subscription)
Parameters
Type Name Description
ReliableMultiSubjectBase.Subscription<> subscription

SubscriptionStart(Int64, ReliableMultiSubjectBase<T>.Subscription)

Declaration
protected virtual void SubscriptionStart(long sequenceId, ReliableMultiSubjectBase<T>.Subscription subscription)
Parameters
Type Name Description
System.Int64 sequenceId
ReliableMultiSubjectBase.Subscription<> subscription

Implements

System.IDisposable