Class MultiSubjectBase<T>

Base class for multi-subjects.

Inheritance
System.Object
MultiSubjectBase<T>
GroupedMultiSubjectBase<TKey, TSource>
MultiSubject<T>
Implements
System.IObservable<T>
System.IDisposable
Namespace: Reaqtive
Assembly: Reaqtive.Core.dll
Syntax
public abstract class MultiSubjectBase<T> : Object, IMultiSubject<T>, IMultiSubject<T, T>, ISubscribable<T>, IObservable<T>, IDisposable
Type Parameters
Name Description
T

Type of the elements processed by the subject.

Constructors

MultiSubjectBase()

Declaration
protected MultiSubjectBase()

Methods

CreateObserver()

Creates a new observer that can be used to push elements into the subject.

Declaration
public IObserver<T> CreateObserver()
Returns
Type Description
System.IObserver<T>

An observer that can be used to push elements into the subject.

CreateObserverCore()

Creates a new observer that can be used to push elements into the subject.

Declaration
protected abstract IObserver<T> CreateObserverCore()
Returns
Type Description
System.IObserver<T>

An observer that can be used to push elements into the subject.

Dispose()

Disposes the subject instance.

Declaration
public void Dispose()

Dispose(Boolean)

Disposes the subject instance.

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

Indicates whether the method is called by Dispose or a finalizer.

Subscribe(IObserver<T>)

Subscribes the specified observer to the subscribable source.

Declaration
public ISubscription Subscribe(IObserver<T> observer)
Parameters
Type Name Description
System.IObserver<T> observer

Observer that will receive the elements of the source.
Returns
Type Description
ISubscription

Handle to the newly created subscription.

SubscribeCore(IObserver<T>)

Subscribes the specified observer to the subscribable source.

Declaration
protected abstract ISubscription SubscribeCore(IObserver<T> observer)
Parameters
Type Name Description
System.IObserver<T> observer

Observer that will receive the elements of the source.
Returns
Type Description
ISubscription

Handle to the newly created subscription.

Implements

System.IObservable<>
System.IDisposable