Class MultiSubjectBase
Base implementation of the non-generic multi-subject.
Namespace: Reaqtive
Assembly: Reaqtive.Core.dll
Syntax
public abstract class MultiSubjectBase : Object, IMultiSubject, IOperator, ISubscription, IDisposableConstructors
MultiSubjectBase()
Declaration
protected MultiSubjectBase()Properties
Inputs
A set of subscriptions to visit upon visiting the current instance.
Declaration
public virtual IEnumerable<ISubscription> Inputs { get; }Property Value
| Type | Description |
|---|---|
| System.Collections.Generic.IEnumerable<ISubscription> |
IsDisposed
Reports whether subject is disposed.
Declaration
protected bool IsDisposed { get; }Property Value
| Type | Description |
|---|---|
| System.Boolean |
Methods
Accept(ISubscriptionVisitor)
Accepts a visitor. Useful, e.g., when we want to perform an action on all
the subscriptions in the graph (e.g., call OnSubscribe). The visitor
will traverse the graph and perform actions on subscriptions. Accept
will accept such actions to be performed.
Declaration
public void Accept(ISubscriptionVisitor visitor)Parameters
| Type | Name | Description |
|---|---|---|
| ISubscriptionVisitor | visitor | Visitor performing the action. |
Dispose()
Defines how subject is disposed of.
Declaration
public void Dispose()Dispose(Boolean)
Disposes the object.
Declaration
protected virtual void Dispose(bool disposing)Parameters
| Type | Name | Description |
|---|---|---|
| System.Boolean | disposing | true if called from System.IDisposable.Dispose; otherwise, false. |
GetObservable<T>()
Gets a subscribable to subscribe to the subject.
Declaration
public ISubscribable<T> GetObservable<T>()Returns
| Type | Description |
|---|---|
| ISubscribable<T> | A subscribable. |
Type Parameters
| Name | Description |
|---|---|
| T | The type of elements. |
GetObservableCore<T>()
Gets a subscribable to subscribe to the subject.
Declaration
protected abstract ISubscribable<T> GetObservableCore<T>()Returns
| Type | Description |
|---|---|
| ISubscribable<T> | A subscribable. |
Type Parameters
| Name | Description |
|---|---|
| T | The type of elements. |
GetObserver<T>()
Gets an observer to push values into the subject.
Declaration
public IObserver<T> GetObserver<T>()Returns
| Type | Description |
|---|---|
| System.IObserver<T> | An observer. |
Type Parameters
| Name | Description |
|---|---|
| T | The type of elements. |
GetObserverCore<T>()
Gets an observer to push values into the subject.
Declaration
protected abstract IObserver<T> GetObserverCore<T>()Returns
| Type | Description |
|---|---|
| System.IObserver<T> | An observer. |
Type Parameters
| Name | Description |
|---|---|
| T | The type of elements. |
OnDispose()
Defines behavior immediately after we Dispose of the subject. This method is
usually called at the very end of the Dispose method.
Declaration
protected virtual void OnDispose()OnStart()
Defines behavior immediately after subject is Started. This method is
usually called at the very end of the Start method.
Declaration
protected virtual void OnStart()SetContext(IOperatorContext)
Sets the operator's current context. Contains things like the reactive service, scheduler, and so on.
Declaration
public virtual void SetContext(IOperatorContext context)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorContext | context | Context data being passed in. |
Start()
Called after the state and/or context are completely initialized; generally subscribes operator to sources, etc.
Declaration
public void Start()Subscribe()
Initializes Inputs.
Declaration
public virtual void Subscribe()