Class ReactiveQubjectFactory
Signatures of the available subject factories to be used in global definitions (DefineStreamFactory). This class does not contain implementations. Expressions using the subject factories have to be rebound to a perticular implementation (Rx or Subscribable) before they can be executed.
Inheritance
Namespace: Reaqtor.Expressions.Core
Assembly: Reaqtor.Expressions.Core.dll
Syntax
public static class ReactiveQubjectFactory : Object
Methods
GetSubjectFactory<T>()
Gets a subject factory.
Declaration
public static IReactiveQubjectFactory<T, T> GetSubjectFactory<T>()
Returns
Type | Description |
---|---|
IReactiveQubjectFactory<T, T> | Instance of a subject factory. |
Type Parameters
Name | Description |
---|---|
T | Type of the elements processed by the subjects returned by the factory. |
MakeQubjectFactory<TInput, TOutput>(IReactiveQueryProvider, Expression<Func<IReactiveQubjectFactory<TInput, TOutput>>>)
Makes a subject factory with the specified expression representation.
Declaration
public static IReactiveQubjectFactory<TInput, TOutput> MakeQubjectFactory<TInput, TOutput>(this IReactiveQueryProvider provider, Expression<Func<IReactiveQubjectFactory<TInput, TOutput>>> expression)
Parameters
Type | Name | Description |
---|---|---|
IReactiveQueryProvider | provider | Query provider to use for creation of the subject factory expression representation. |
System.Linq.Expressions.Expression<System.Func<IReactiveQubjectFactory<TInput, TOutput>>> | expression | Expression representation of the subject factory. |
Returns
Type | Description |
---|---|
IReactiveQubjectFactory<TInput, TOutput> | Instance of a subject factory with the specified expression tree as its representation. |
Type Parameters
Name | Description |
---|---|
TInput | Type of the elements received by the subjects returned by the factory. |
TOutput | Type of the elements produced by the subjects returned by the factory. |
MakeQubjectFactory<TArg, TInput, TOutput>(IReactiveQueryProvider, Expression<Func<IReactiveQubjectFactory<TInput, TOutput, TArg>>>)
Makes a parameterized subject factory with the specified expression representation.
Declaration
public static IReactiveQubjectFactory<TInput, TOutput, TArg> MakeQubjectFactory<TArg, TInput, TOutput>(this IReactiveQueryProvider provider, Expression<Func<IReactiveQubjectFactory<TInput, TOutput, TArg>>> expression)
Parameters
Type | Name | Description |
---|---|---|
IReactiveQueryProvider | provider | Query provider to use for creation of the subject factory expression representation. |
System.Linq.Expressions.Expression<System.Func<IReactiveQubjectFactory<TInput, TOutput, TArg>>> | expression | Expression representation of the subject factory. |
Returns
Type | Description |
---|---|
IReactiveQubjectFactory<TInput, TOutput, TArg> | Instance of a parameterized subject factory with the specified expression tree as its representation. |
Type Parameters
Name | Description |
---|---|
TArg | Type of the argument passed to the stream factory. |
TInput | Type of the elements received by the subjects returned by the factory. |
TOutput | Type of the elements produced by the subjects returned by the factory. |