Class StatefulMultiSubjectBase
Base implementation of the non-generic multi-subject, with support for checkpointing.
Inherited Members
Namespace: Reaqtive
Assembly: Reaqtive.Core.dll
Syntax
public abstract class StatefulMultiSubjectBase : VersionedMultiSubjectBase, IMultiSubject, ISubscription, IStatefulOperator, IOperator, IDisposable, IVersionedConstructors
StatefulMultiSubjectBase()
Declaration
protected StatefulMultiSubjectBase()Properties
StateChanged
Gets a flag indicating whether state has changed since the last time the subject state got saved.
Declaration
public virtual bool StateChanged { get; protected set; }Property Value
| Type | Description |
|---|---|
| System.Boolean |
Methods
LoadState(IOperatorStateReader, Version)
Loads the state of the subject.
Declaration
public void LoadState(IOperatorStateReader reader, Version version)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateReader | reader | Reader to read subject state from. |
| System.Version | version | Version of the state. |
LoadStateCore(IOperatorStateReader)
Loads the state of the subject.
Declaration
protected virtual void LoadStateCore(IOperatorStateReader reader)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateReader | reader | Reader to read subject state from. |
LoadStateCore(IOperatorStateReader, Version)
Loads the state of the subject using the specified state version.
Declaration
protected virtual void LoadStateCore(IOperatorStateReader reader, Version version)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateReader | reader | Reader to read subject state from. |
| System.Version | version | Version of the state being read. |
OnDispose()
Called when the subject is disposed.
Declaration
protected override void OnDispose()Overrides
OnStateSaved()
Called when subject state was successfully saved.
Declaration
public virtual void OnStateSaved()SaveState(IOperatorStateWriter, Version)
Saves the state of the operator.
Declaration
public void SaveState(IOperatorStateWriter writer, Version version)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateWriter | writer | Writer to write operator state to. |
| System.Version | version | Version of the state being saved. |
SaveStateCore(IOperatorStateWriter)
Saves the state of the subject.
Declaration
protected virtual void SaveStateCore(IOperatorStateWriter writer)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateWriter | writer | Writer to write subject state to. |
SaveStateCore(IOperatorStateWriter, Version)
Saves the state of the subject using the specified state version.
Declaration
protected virtual void SaveStateCore(IOperatorStateWriter writer, Version version)Parameters
| Type | Name | Description |
|---|---|---|
| IOperatorStateWriter | writer | Writer to write subject state to. |
| System.Version | version | Version of the state being written. |