Interface IReactiveSubjectFactory<TInput, TOutput, TArgs>
Interface for a parameterized subject factory.
Namespace: Reaqtor
Assembly: Reaqtor.Local.Model.dll
Syntax
public interface IReactiveSubjectFactory<TInput, TOutput, TArgs>
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. |
TArgs | Type of the parameter passed to the subject factory. |
Methods
Create(Uri, TArgs, Object)
Creates a new subject with the specified stream URI.
Declaration
IReactiveSubject<TInput, TOutput> Create(Uri streamUri, TArgs argument, object state = null)
Parameters
Type | Name | Description |
---|---|---|
System.Uri | streamUri | URI identifying the stream. |
TArgs | argument | Parameter to pass to the subject factory. |
System.Object | state | Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it. |
Returns
Type | Description |
---|---|
IReactiveSubject<TInput, TOutput> | A subject object that can be used to send and receive data on the stream, or an exception if the creation request was unsuccessful. |