Class ReliableReactiveObserverBase<T>

Inheritance
System.Object
ReliableReactiveObserverBase<T>
ReliableQbserverBase<T>
Namespace: Reaqtor.Reliable.Client
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableReactiveObserverBase<T> : Object, IReliableReactiveObserver<T>, IReliableObserver<T>
Type Parameters
Name Description
T

Constructors

ReliableReactiveObserverBase()

Declaration
protected ReliableReactiveObserverBase()

Properties

ResubscribeUri

Declaration
public abstract Uri ResubscribeUri { get; }
Property Value
Type Description
System.Uri

Methods

OnCompleted()

Declaration
public void OnCompleted()

OnCompletedCore()

Declaration
protected abstract void OnCompletedCore()

OnError(Exception)

Declaration
public void OnError(Exception error)
Parameters
Type Name Description
System.Exception error

OnErrorCore(Exception)

Declaration
protected abstract void OnErrorCore(Exception error)
Parameters
Type Name Description
System.Exception error

OnNext(T, Int64)

Declaration
public void OnNext(T item, long sequenceId)
Parameters
Type Name Description
T item
System.Int64 sequenceId

OnNextCore(T, Int64)

Declaration
protected abstract void OnNextCore(T item, long sequenceId)
Parameters
Type Name Description
T item
System.Int64 sequenceId

OnStarted()

Declaration
public void OnStarted()

OnStartedCore()

Declaration
protected abstract void OnStartedCore()

Implements