Show / Hide Table of Contents

Class ReliableQubject<TInput, TOutput>

Inheritance
System.Object
ReliableReactiveMultiSubjectBase<TInput, TOutput>
ReliableQubjectBase<TInput, TOutput>
ReliableQubject<TInput, TOutput>
KnownReliableQubject<TInput, TOutput>
Implements
IReliableMultiQubject<TInput, TOutput>
IReliableReactiveMultiSubject<TInput, TOutput>
System.IDisposable
IReliableQbservable<TOutput>
IReliableReactiveObservable<TOutput>
IReliableMultiQubject
IReliableQbservable
IReliableReactiveExpressible
IExpressible
Inherited Members
ReliableQubjectBase<TInput, TOutput>.Subscribe(IReliableQbserver<TOutput>, Uri, Object)
ReliableQubjectBase<TInput, TOutput>.SubscribeCore(IReliableQbserver<TOutput>, Uri, Object)
ReliableQubjectBase<TInput, TOutput>.SubscribeCore(IReliableReactiveObserver<TOutput>, Uri, Object)
ReliableQubjectBase<TInput, TOutput>.CreateObserver()
ReliableQubjectBase<TInput, TOutput>.CreateQbserverCore()
ReliableQubjectBase<TInput, TOutput>.CreateObserverCore()
ReliableQubjectBase<TInput, TOutput>.InputType
ReliableQubjectBase<TInput, TOutput>.OutputType
ReliableQubjectBase<TInput, TOutput>.ElementType
ReliableQubjectBase<TInput, TOutput>.Provider
ReliableQubjectBase<TInput, TOutput>.Expression
ReliableReactiveMultiSubjectBase<TInput, TOutput>.CreateObserver()
ReliableReactiveMultiSubjectBase<TInput, TOutput>.CreateObserverCore()
ReliableReactiveMultiSubjectBase<TInput, TOutput>.Subscribe(IReliableReactiveObserver<TOutput>, Uri, Object)
ReliableReactiveMultiSubjectBase<TInput, TOutput>.SubscribeCore(IReliableReactiveObserver<TOutput>, Uri, Object)
ReliableReactiveMultiSubjectBase<TInput, TOutput>.Dispose()
ReliableReactiveMultiSubjectBase<TInput, TOutput>.Dispose(Boolean)
ReliableReactiveMultiSubjectBase<TInput, TOutput>.DisposeCore()
Namespace: Reaqtor.Reliable.Service
Assembly: Reaqtor.Reliable.dll
Syntax
public class ReliableQubject<TInput, TOutput> : ReliableQubjectBase<TInput, TOutput>, IReliableMultiQubject<TInput, TOutput>, IReliableReactiveMultiSubject<TInput, TOutput>, IDisposable, IReliableQbservable<TOutput>, IReliableReactiveObservable<TOutput>, IReliableMultiQubject, IReliableQbservable, IReliableReactiveExpressible, IExpressible
Type Parameters
Name Description
TInput
TOutput

Constructors

ReliableQubject(Expression, IReliableQueryProvider)

Declaration
public ReliableQubject(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.ReliableQubjectBase<TInput, TOutput>.Expression

Methods

CreateQbserverCore()

Declaration
protected override IReliableQbserver<TInput> CreateQbserverCore()
Returns
Type Description
IReliableQbserver<TInput>
Overrides
Reaqtor.Reliable.Expressions.ReliableQubjectBase<TInput, TOutput>.CreateQbserverCore()

DisposeCore()

Declaration
protected override void DisposeCore()
Overrides
Reaqtor.Reliable.Client.ReliableReactiveMultiSubjectBase<TInput, TOutput>.DisposeCore()

SubscribeCore(IReliableQbserver<TOutput>, Uri, Object)

Declaration
protected override 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
Overrides
Reaqtor.Reliable.Expressions.ReliableQubjectBase<TInput, TOutput>.SubscribeCore(Reaqtor.Reliable.Expressions.IReliableQbserver<TOutput>, System.Uri, System.Object)

Implements

IReliableMultiQubject<TInput, TOutput>
IReliableReactiveMultiSubject<TInput, TOutput>
System.IDisposable
IReliableQbservable<T>
IReliableReactiveObservable<T>
IReliableMultiQubject
IReliableQbservable
IReliableReactiveExpressible
IExpressible
In This Article
Back to top Generated by DocFX