Class MultiSubject<T>

Base class for multi-subjects.

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

Type of the elements processed by the subject.

Constructors

MultiSubject()

Declaration
public MultiSubject()

Methods

CreateObserverCore()

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

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

An observer that can be used to push elements into the subject.
Overrides
Reaqtive.MultiSubjectBase<T>.CreateObserverCore()

Dispose(Boolean)

Disposes the subject instance.

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

Indicates whether the method is called by Dispose or a finalizer.
Overrides
Reaqtive.MultiSubjectBase<T>.Dispose(System.Boolean)

SubscribeCore(IObserver<T>)

Subscribes the specified observer to the subscribable source.

Declaration
protected override 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.
Overrides
Reaqtive.MultiSubjectBase<T>.SubscribeCore(System.IObserver<T>)

Implements

System.IObservable<>
System.IDisposable