Interface IReactiveSubjectFactory<TInput, TOutput>
Interface for a subject factory.
Namespace: Reaqtor
Assembly: Reaqtor.Local.Model.dll
Syntax
public interface IReactiveSubjectFactory<TInput, TOutput>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. |
Methods
Create(Uri, Object)
Creates a new subject with the specified stream URI.
Declaration
IReactiveSubject<TInput, TOutput> Create(Uri streamUri, object state = null)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | streamUri | URI identifying the stream. |
| 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. |