Class ReliableMultiSubject<T>

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

Constructors

ReliableMultiSubject()

Declaration
public ReliableMultiSubject()

Properties

Id

Declaration
public override Uri Id { get; }
Property Value
Type Description
System.Uri
Overrides
Reaqtor.Reliable.ReliableMultiSubjectBase<T>.Id

Inputs

Declaration
public IEnumerable<ISubscription> Inputs { get; }
Property Value
Type Description
System.Collections.Generic.IEnumerable<ISubscription>

Name

Declaration
public string Name { get; }
Property Value
Type Description
System.String

Version

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

Methods

DisposeCore()

Declaration
protected override void DisposeCore()
Overrides
Reaqtor.Reliable.ReliableMultiSubjectBase<T>.DisposeCore()

OnCompleted()

Declaration
protected override void OnCompleted()
Overrides
Reaqtor.Reliable.ReliableMultiSubjectBase<T>.OnCompleted()

OnError(Exception)

Declaration
protected override void OnError(Exception error)
Parameters
Type Name Description
System.Exception error
Overrides
Reaqtor.Reliable.ReliableMultiSubjectBase<T>.OnError(System.Exception)

OnNext(T, Int64)

Declaration
protected override void OnNext(T item, long sequenceId)
Parameters
Type Name Description
T item
System.Int64 sequenceId
Overrides
Reaqtor.Reliable.ReliableMultiSubjectBase<T>.OnNext(T, System.Int64)

SetContext(IOperatorContext)

Declaration
public void SetContext(IOperatorContext context)
Parameters
Type Name Description
IOperatorContext context

ShouldBufferedEventsBeDropped()

Declaration
protected override bool ShouldBufferedEventsBeDropped()
Returns
Type Description
System.Boolean
Overrides
Reaqtor.Reliable.ReliableMultiSubjectBase<T>.ShouldBufferedEventsBeDropped()

Subscribe()

Declaration
public void Subscribe()

Implements

System.IDisposable