Interface IReactiveObserver<T>
Interface for observers of event streams.
Namespace: Reaqtor
Assembly: Reaqtor.Local.Model.dll
Syntax
public interface IReactiveObserver<in T> : IObserver<T>Type Parameters
| Name | Description |
|---|---|
| T | Type of the data received by the observer. |
Methods
OnCompleted()
Reports completion of the stream.
Declaration
void OnCompleted()Remarks
If observer calls are not awaited in a sequential manner, the order of events in the stream as observed by the server is undefined.
OnError(Exception)
Reports an error to the stream.
Declaration
void OnError(Exception error)Parameters
| Type | Name | Description |
|---|---|---|
| System.Exception | error | Error to report on the stream. |
Remarks
If observer calls are not awaited in a sequential manner, the order of events in the stream as observed by the server is undefined.
OnNext(T)
Sends a value to the stream.
Declaration
void OnNext(T value)Parameters
| Type | Name | Description |
|---|---|---|
| T | value | Object to send to the stream. |
Remarks
If observer calls are not awaited in a sequential manner, the order of events in the stream as observed by the server is undefined.