Class ReliableQubjectFactoryBase<TInput, TOutput, TArg>

Inheritance
System.Object
ReliableQubjectFactoryBase<TInput, TOutput, TArg>
ReliableQubjectFactory<TInput, TOutput, TArg>
Namespace: Reaqtor.Reliable.Expressions
Assembly: Reaqtor.Reliable.dll
Syntax
public abstract class ReliableQubjectFactoryBase<TInput, TOutput, TArg> : Object, IReliableQubjectFactory<TInput, TOutput, TArg>, IReliableReactiveSubjectFactory<TInput, TOutput, TArg>, IReliableReactiveExpressible, IExpressible
Type Parameters
Name Description
TInput
TOutput
TArg

Constructors

ReliableQubjectFactoryBase(IReliableQueryProvider)

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

Properties

Expression

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

Provider

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

Methods

Create(Uri, TArg, Object)

Declaration
public IReliableMultiQubject<TInput, TOutput> Create(Uri streamUri, TArg argument, object state = null)
Parameters
Type Name Description
System.Uri streamUri
TArg argument
System.Object state
Returns
Type Description
IReliableMultiQubject<TInput, TOutput>

CreateCore(Uri, TArg, Object)

Declaration
protected abstract IReliableMultiQubject<TInput, TOutput> CreateCore(Uri streamUri, TArg argument, object state)
Parameters
Type Name Description
System.Uri streamUri
TArg argument
System.Object state
Returns
Type Description
IReliableMultiQubject<TInput, TOutput>

Explicit Interface Implementations

IReliableReactiveSubjectFactory<TInput, TOutput, TArg>.Create(Uri, TArg, Object)

Declaration
IReliableReactiveMultiSubject<TInput, TOutput> IReliableReactiveSubjectFactory<TInput, TOutput, TArg>.Create(Uri streamUri, TArg argument, object state)
Parameters
Type Name Description
System.Uri streamUri
TArg argument
System.Object state
Returns
Type Description
IReliableReactiveMultiSubject<TInput, TOutput>

Implements