System.Reactive.ObserverBase<T>

ObserverBase<T>

public abstract class ObserverBase<T> : IObserver<T>, IDisposable

Abstract base class for implementations of the IObserver<T> interface.

protected ObserverBase()

Creates a new observer in a non-stopped state.

public void Dispose()

Disposes the observer, causing it to transition to the stopped state.

protected virtual void Dispose(bool disposing)

Core implementation of IDisposable.

public void OnCompleted()

Notifies the observer of the end of the sequence.

protected abstract void OnCompletedCore()

Implement this method to react to the end of the sequence.

public void OnError(Exception error)

Notifies the observer that an exception has occurred.

protected abstract void OnErrorCore(Exception error)

Implement this method to react to the occurrence of an exception.

public void OnNext(T value)

Notifies the observer of a new element in the sequence.

protected abstract void OnNextCore(T value)

Implement this method to react to the receival of a new element in the sequence.