Class ReliableQubject<TInput, TOutput>
Inheritance
System.Object
ReliableReactiveMultiSubjectBase<TInput, TOutput>
ReliableQubjectBase<TInput, TOutput>
ReliableQubject<TInput, TOutput>
Implements
IReliableMultiQubject<TInput, TOutput>
IReliableReactiveMultiSubject<TInput, TOutput>
System.IDisposable
IReliableQbservable<TOutput>
IReliableReactiveObservable<TOutput>
Inherited Members
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
System.IDisposable