Class ReliableQbserver<T>

Inheritance
System.Object
ReliableReactiveObserverBase<T>
ReliableQbserverBase<T>
ReliableQbserver<T>
KnownReliableQbserver<T>
Inherited Members
Namespace: Reaqtor.Reliable.Service
Assembly: Reaqtor.Reliable.dll
Syntax
public class ReliableQbserver<T> : ReliableQbserverBase<T>, IReliableQbserver<T>, IReliableReactiveObserver<T>, IReliableObserver<T>, IReliableQbserver, IReliableReactiveExpressible, IExpressible
Type Parameters
Name Description
T

Constructors

ReliableQbserver(Expression, IReliableQueryProvider)

Declaration
public ReliableQbserver(Expression expression, IReliableQueryProvider provider)
Parameters
Type Name Description
System.Linq.Expressions.Expression expression
IReliableQueryProvider provider

Properties

Expression

Declaration
public override Expression Expression { get; }
Property Value
Type Description
System.Linq.Expressions.Expression
Overrides
Reaqtor.Reliable.Expressions.ReliableQbserverBase<T>.Expression

ResubscribeUri

Declaration
public override Uri ResubscribeUri { get; }
Property Value
Type Description
System.Uri
Overrides
Reaqtor.Reliable.Client.ReliableReactiveObserverBase<T>.ResubscribeUri

Methods

OnCompletedCore()

Declaration
protected override void OnCompletedCore()
Overrides
Reaqtor.Reliable.Client.ReliableReactiveObserverBase<T>.OnCompletedCore()

OnErrorCore(Exception)

Declaration
protected override void OnErrorCore(Exception error)
Parameters
Type Name Description
System.Exception error
Overrides
Reaqtor.Reliable.Client.ReliableReactiveObserverBase<T>.OnErrorCore(System.Exception)

OnNextCore(T, Int64)

Declaration
protected override void OnNextCore(T item, long sequenceId)
Parameters
Type Name Description
T item
System.Int64 sequenceId
Overrides
Reaqtor.Reliable.Client.ReliableReactiveObserverBase<T>.OnNextCore(T, System.Int64)

OnStartedCore()

Declaration
protected override void OnStartedCore()
Overrides
Reaqtor.Reliable.Client.ReliableReactiveObserverBase<T>.OnStartedCore()

Implements