Class ObserverBase<T>
Base class for observer implementations.
Implements
System.IObserver<T>
Namespace: Reaqtive
Assembly: Reaqtive.Core.dll
Syntax
public abstract class ObserverBase<T> : Object, IObserver<T>Type Parameters
| Name | Description |
|---|---|
| T | Type of the elements received by the subject. |
Constructors
ObserverBase()
Declaration
protected ObserverBase()Methods
OnCompleted()
Pushes a completion notification into the observer.
Declaration
public void OnCompleted()OnCompletedCore()
Pushes a completion notification into the observer.
Declaration
protected abstract void OnCompletedCore()OnError(Exception)
Pushes the specified error into the observer.
Declaration
public void OnError(Exception error)Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | error | Error to push into the observer. |
OnErrorCore(Exception)
Pushes the specified error into the observer.
Declaration
protected abstract void OnErrorCore(Exception error)Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | error | Error to push into the observer. |
OnNext(T)
Pushes the specified value into the observer.
Declaration
public void OnNext(T value)Parameters
| Type | Name | Description |
|---|---|---|
| T | value | Value to push into the observer. |
OnNextCore(T)
Pushes the specified value into the observer.
Declaration
protected abstract void OnNextCore(T value)Parameters
| Type | Name | Description |
|---|---|---|
| T | value | Value to push into the observer. |
Implements
System.IObserver<>