Interface IAsyncReactiveStreamFactoryDefinition

Interface representing a stream factory definition in a reactive processing service.

Inherited Members
Namespace: Reaqtor.Metadata
Assembly: Reaqtor.Metadata.Model.dll
Syntax
public interface IAsyncReactiveStreamFactoryDefinition : IAsyncReactiveDefinedResource, IAsyncReactiveResource, IKnownResource, IExpressible

Methods

ToStreamFactory<TInput, TOutput>()

Gets the stream factory defined by the definition.

Declaration
IAsyncReactiveQubjectFactory<TInput, TOutput> ToStreamFactory<TInput, TOutput>()
Returns
Type Description
IAsyncReactiveQubjectFactory<TInput, TOutput>

Representation of the stream factory defined by the definition.
Type Parameters
Name Description
TInput

Type of the data received by the subjects created by the stream factory.
TOutput

Type of the data produced by the subjects created by the stream factory.
Remarks

This method can be used in isolation from the client library. It's allowed to return an object that encapsulates the definition using an expression tree, to be used for composition and delegation to other systems. The object does not have to provide data operations, as is expected from the client library proxy objects.

ToStreamFactory<TArgs, TInput, TOutput>()

Gets the parameterized stream factory defined by the definition.

Declaration
IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs> ToStreamFactory<TArgs, TInput, TOutput>()
Returns
Type Description
IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs>

Representation of the parameterized stream factory defined by the definition.
Type Parameters
Name Description
TArgs

Type of the parameter passed to the stream factory.
TInput

Type of the data received by the subjects created by the stream factory.
TOutput

Type of the data produced by the subjects created by the stream factory.
Remarks

This method can be used in isolation from the client library. It's allowed to return an object that encapsulates the definition using an expression tree, to be used for composition and delegation to other systems. The object does not have to provide data operations, as is expected from the client library proxy objects.