Class ReliableQubjectBase<TInput, TOutput>

Inheritance
System.Object
ReliableReactiveMultiSubjectBase<TInput, TOutput>
ReliableQubjectBase<TInput, TOutput>
ReliableQubject<TInput, TOutput>
Inherited Members
Namespace: Reaqtor.Reliable.Expressions
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableQubjectBase<TInput, TOutput> : ReliableReactiveMultiSubjectBase<TInput, TOutput>, IReliableMultiQubject<TInput, TOutput>, IReliableReactiveMultiSubject<TInput, TOutput>, IDisposable, IReliableQbservable<TOutput>, IReliableReactiveObservable<TOutput>, IReliableMultiQubject, IReliableQbservable, IReliableReactiveExpressible, IExpressible
Type Parameters
Name Description
TInput
TOutput

Constructors

ReliableQubjectBase(IReliableQueryProvider)

Declaration
protected ReliableQubjectBase(IReliableQueryProvider provider)
Parameters
Type Name Description
IReliableQueryProvider provider

Properties

ElementType

Declaration
public Type ElementType { get; }
Property Value
Type Description
System.Type

Expression

Declaration
public abstract Expression Expression { get; }
Property Value
Type Description
System.Linq.Expressions.Expression

InputType

Declaration
protected Type InputType { get; }
Property Value
Type Description
System.Type

OutputType

Declaration
protected Type OutputType { get; }
Property Value
Type Description
System.Type

Provider

Declaration
public IReliableQueryProvider Provider { get; }
Property Value
Type Description
IReliableQueryProvider

Methods

CreateObserver()

Declaration
public IReliableQbserver<TInput> CreateObserver()
Returns
Type Description
IReliableQbserver<TInput>

CreateObserverCore()

Declaration
protected override IReliableReactiveObserver<TInput> CreateObserverCore()
Returns
Type Description
IReliableReactiveObserver<TInput>
Overrides
Reaqtor.Reliable.Client.ReliableReactiveMultiSubjectBase<TInput, TOutput>.CreateObserverCore()

CreateQbserverCore()

Declaration
protected abstract IReliableQbserver<TInput> CreateQbserverCore()
Returns
Type Description
IReliableQbserver<TInput>

Subscribe(IReliableQbserver<TOutput>, Uri, Object)

Declaration
public IReliableQubscription Subscribe(IReliableQbserver<TOutput> observer, Uri subscriptionUri, object state = null)
Parameters
Type Name Description
IReliableQbserver<TOutput> observer
System.Uri subscriptionUri
System.Object state
Returns
Type Description
IReliableQubscription

SubscribeCore(IReliableReactiveObserver<TOutput>, Uri, Object)

Declaration
protected override IReliableReactiveSubscription SubscribeCore(IReliableReactiveObserver<TOutput> observer, Uri subscriptionUri, object state)
Parameters
Type Name Description
IReliableReactiveObserver<TOutput> observer
System.Uri subscriptionUri
System.Object state
Returns
Type Description
IReliableReactiveSubscription
Overrides
Reaqtor.Reliable.Client.ReliableReactiveMultiSubjectBase<TInput, TOutput>.SubscribeCore(Reaqtor.Reliable.Client.IReliableReactiveObserver<TOutput>, System.Uri, System.Object)

SubscribeCore(IReliableQbserver<TOutput>, Uri, Object)

Declaration
protected abstract IReliableQubscription SubscribeCore(IReliableQbserver<TOutput> observer, Uri subscriptionUri, object state)
Parameters
Type Name Description
IReliableQbserver<TOutput> observer
System.Uri subscriptionUri
System.Object state
Returns
Type Description
IReliableQubscription

Implements

System.IDisposable