Class StatefulObserver<T>

Base class for stateful observer implementations, providing support to load and save observer state during checkpointing and recovery.

Inheritance

System.Object

ObserverBase<T>

Observer<T>

VersionedObserver<T>

StatefulObserver<T>

Implements

System.IObserver<T>

System.IDisposable

Inherited Members

VersionedObserver<T>.Name

VersionedObserver<T>.Version

Observer<T>.Subscribe()

Observer<T>.SetContext(IOperatorContext)

Observer<T>.Accept(ISubscriptionVisitor)

Observer<T>.OnSubscribe()

Observer<T>.Start()

Observer<T>.Dispose()

Observer<T>.Dispose(Boolean)

Observer<T>.OnStart()

Observer<T>.Inputs

Observer<T>.IsDisposed

ObserverBase<T>.OnCompleted()

ObserverBase<T>.OnCompletedCore()

ObserverBase<T>.OnError(Exception)

ObserverBase<T>.OnErrorCore(Exception)

ObserverBase<T>.OnNext(T)

ObserverBase<T>.OnNextCore(T)

Namespace: Reaqtive

Assembly: Reaqtive.Core.dll

Syntax

public abstract class StatefulObserver<T> : VersionedObserver<T>, IObserver<T>, ISubscription, IStatefulOperator, IOperator, IDisposable, IVersioned

Type Parameters

Name	Description
T	Type of the objects received by the observer.

Constructors

StatefulObserver()

Declaration

protected StatefulObserver()

Properties

StateChanged

Gets a flag indicating whether state has changed since the last time the observer 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 observer.

Declaration

public void LoadState(IOperatorStateReader reader, Version version)

Parameters

Type	Name	Description
IOperatorStateReader	reader	Reader to read observer state from.
System.Version	version	Version of the state.

LoadStateCore(IOperatorStateReader)

Loads the state of the observer.

Declaration

protected virtual void LoadStateCore(IOperatorStateReader reader)

Parameters

Type	Name	Description
IOperatorStateReader	reader	Reader to read observer state from.

LoadStateCore(IOperatorStateReader, Version)

Loads the state of the observer using the specified state version.

Declaration

protected virtual void LoadStateCore(IOperatorStateReader reader, Version version)

Parameters

Type	Name	Description
IOperatorStateReader	reader	Reader to read observer state from.
System.Version	version	Version of the state being read.

OnDispose()

Called when the observer is disposed.

Declaration

protected override void OnDispose()

Overrides

Reaqtive.Observer<T>.OnDispose()

OnStateSaved()

Called when observer 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 observer.

Declaration

protected virtual void SaveStateCore(IOperatorStateWriter writer)

Parameters

Type	Name	Description
IOperatorStateWriter	writer	Writer to write observer state to.

SaveStateCore(IOperatorStateWriter, Version)

Saves the state of the observer using the specified state version.

Declaration

protected virtual void SaveStateCore(IOperatorStateWriter writer, Version version)

Parameters

Type	Name	Description
IOperatorStateWriter	writer	Writer to write observer state to.
System.Version	version	Version of the state being written.

Implements

System.IObserver<>

ISubscription

IStatefulOperator

IOperator

System.IDisposable

IVersioned