Class ReliableReactiveMultiSubjectBase<TInput, TOutput>

Inheritance
System.Object
ReliableReactiveMultiSubjectBase<TInput, TOutput>
ReliableQubjectBase<TInput, TOutput>
Implements
System.IDisposable
Namespace: Reaqtor.Reliable.Client
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableReactiveMultiSubjectBase<TInput, TOutput> : Object, IReliableReactiveMultiSubject<TInput, TOutput>, IReliableReactiveObservable<TOutput>, IDisposable
Type Parameters
Name Description
TInput
TOutput

Constructors

ReliableReactiveMultiSubjectBase()

Declaration
protected ReliableReactiveMultiSubjectBase()

Methods

CreateObserver()

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

CreateObserverCore()

Declaration
protected abstract IReliableReactiveObserver<TInput> CreateObserverCore()
Returns
Type Description
IReliableReactiveObserver<TInput>

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()

Subscribe(IReliableReactiveObserver<TOutput>, Uri, Object)

Declaration
public IReliableReactiveSubscription Subscribe(IReliableReactiveObserver<TOutput> observer, Uri subscriptionUri, object state = null)
Parameters
Type Name Description
IReliableReactiveObserver<TOutput> observer
System.Uri subscriptionUri
System.Object state
Returns
Type Description
IReliableReactiveSubscription

SubscribeCore(IReliableReactiveObserver<TOutput>, Uri, Object)

Declaration
protected abstract IReliableReactiveSubscription SubscribeCore(IReliableReactiveObserver<TOutput> observer, Uri subscriptionUri, object state)
Parameters
Type Name Description
IReliableReactiveObserver<TOutput> observer
System.Uri subscriptionUri
System.Object state
Returns
Type Description
IReliableReactiveSubscription

Implements

System.IDisposable