Class VersionedObserver<T>

Base class for observers with state versioning capabilities.

Inheritance

System.Object

ObserverBase<T>

Observer<T>

VersionedObserver<T>

StatefulObserver<T>

Implements

System.IObserver<T>

IOperator

ISubscription

System.IDisposable

IVersioned

Inherited Members

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>.OnDispose()

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 VersionedObserver<T> : Observer<T>, IObserver<T>, IOperator, ISubscription, IDisposable, IVersioned

Type Parameters

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

Constructors

VersionedObserver()

Declaration

protected VersionedObserver()

Properties

Name

Gets the name tag of the observer, used to persist state headers.

Declaration

public abstract string Name { get; }

Property Value

Type	Description
System.String

Version

Gets the version of the observer.

Declaration

public abstract Version Version { get; }

Property Value

Type	Description
System.Version

Implements

System.IObserver<>

IOperator

ISubscription

System.IDisposable

IVersioned