Class ReliableMultiSubjectProxy<TInput, TOutput>

Inheritance
System.Object
ReliableMultiSubjectProxy<TInput, TOutput>
Implements
IReliableMultiSubject<TInput, TOutput>
System.IDisposable
Namespace: Reaqtor.Reliable
Assembly: Reaqtor.Reliable.dll
Syntax
public sealed class ReliableMultiSubjectProxy<TInput, TOutput> : Object, IReliableMultiSubject<TInput, TOutput>, IReliableMultiSubject, IDisposable, IReliableObservable<TOutput>
Type Parameters
Name Description
TInput
TOutput

Constructors

ReliableMultiSubjectProxy(Uri)

Declaration
public ReliableMultiSubjectProxy(Uri uri)
Parameters
Type Name Description
System.Uri uri

Methods

CreateObserver()

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

Dispose()

Declaration
public void Dispose()

Subscribe(IReliableObserver<TOutput>)

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

Implements

System.IDisposable