Show / Hide Table of Contents

Interface IAsyncReactiveSubjectFactory<TInput, TOutput, TArg1, TArg2>

Interface for a parameterized subject factory.

Namespace: Reaqtor
Assembly: Reaqtor.Local.Model.dll
Syntax
public interface 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.

Methods

CreateAsync(Uri, TArg1, TArg2, Object, CancellationToken)

Creates a new subject with the specified stream URI.

Declaration
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 state to pass to the operation. 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.

In This Article
Back to top Generated by DocFX