Class AsyncReactiveSubjectFactoryBase<TInput, TOutput, TArg1, TArg2>
Base class for stream factories.
Inheritance
Implements
Namespace: Reaqtor
Assembly: Reaqtor.Local.Core.dll
Syntax
public abstract class AsyncReactiveSubjectFactoryBase<TInput, TOutput, TArg1, TArg2> : Object, IAsyncReactiveSubjectFactory<TInput, TOutput, TArg1, TArg2>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. |
| TArg1 | Type of the first parameter passed to the subject factory. |
| TArg2 | Type of the second parameter passed to the subject factory. |
Constructors
AsyncReactiveSubjectFactoryBase()
Declaration
protected AsyncReactiveSubjectFactoryBase()Methods
CreateAsync(Uri, TArg1, TArg2, Object, CancellationToken)
Creates a new subject with the specified stream URI.
Declaration
public Task<IAsyncReactiveSubject<TInput, TOutput>> CreateAsync(Uri streamUri, TArg1 arg1, TArg2 arg2, object state = null, CancellationToken token = null)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | streamUri | URI identifying the stream. |
| TArg1 | arg1 | First parameter to pass to the subject factory. |
| TArg2 | arg2 | Second 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. |
| System.Threading.CancellationToken | token | Token to observe for cancellation of the request. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task<IAsyncReactiveSubject<TInput, TOutput>> | Task returning a subject object that can be used to send and receive data on the stream, or an exception if the creation request was unsuccessful. |
CreateAsyncCore(Uri, TArg1, TArg2, Object, CancellationToken)
Creates a new subject with the specified stream URI.
Declaration
protected abstract Task<IAsyncReactiveSubject<TInput, TOutput>> CreateAsyncCore(Uri streamUri, TArg1 arg1, TArg2 arg2, object state, CancellationToken token)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | streamUri | URI identifying the stream. |
| TArg1 | arg1 | First parameter to pass to the subject factory. |
| TArg2 | arg2 | Second 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. |
| System.Threading.CancellationToken | token | Token to observe for cancellation of the request. |
Returns
| Type | Description |
|---|---|
| System.Threading.Tasks.Task<IAsyncReactiveSubject<TInput, TOutput>> | Task returning a subject object that can be used to send and receive data on the stream, or an exception if the creation request was unsuccessful. |