Class ReactiveObserverBase<T>
Base class for observers.
Namespace: Reaqtor
Assembly: Reaqtor.Local.Core.dll
Syntax
public abstract class ReactiveObserverBase<T> : Object, IReactiveObserver<T>, IObserver<T>Type Parameters
| Name | Description |
|---|---|
| T | Type of the data received by the observable. |
Constructors
ReactiveObserverBase()
Declaration
protected ReactiveObserverBase()Methods
OnCompleted()
Reports completion of the observer.
Declaration
public void OnCompleted()OnCompletedCore()
Reports completion of the observer.
Declaration
protected abstract void OnCompletedCore()OnError(Exception)
Reports an error to the observer.
Declaration
public void OnError(Exception error)Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | error | Error to report on the observer. |
OnErrorCore(Exception)
Reports an error to the observer.
Declaration
protected abstract void OnErrorCore(Exception error)Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | error | Error to report on the observer. |
OnNext(T)
Sends a value to the observer.
Declaration
public void OnNext(T value)Parameters
| Type | Name | Description |
|---|---|---|
| T | value | Object to send to the observer. |
OnNextCore(T)
Sends a value to the observer.
Declaration
protected abstract void OnNextCore(T value)Parameters
| Type | Name | Description |
|---|---|---|
| T | value | Object to send to the observer. |
Implements
System.IObserver<>