Interface IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs>

Interface for a parameterized subject factory.

Inherited Members

IAsyncReactiveSubjectFactory<TInput, TOutput, TArgs>.CreateAsync(Uri, TArgs, Object, CancellationToken)

IAsyncReactiveExpressible.Provider

IExpressible.Expression

Namespace: Reaqtor

Assembly: Reaqtor.Expressions.Model.dll

Syntax

public interface IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs> : IAsyncReactiveSubjectFactory<TInput, TOutput, TArgs>, IAsyncReactiveExpressible, IExpressible

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

CreateAsync(Uri, TArgs, Object, CancellationToken)

Creates a new subject with the specified stream URI.

Declaration

Task<IAsyncReactiveQubject<TInput, TOutput>> CreateAsync(Uri streamUri, TArgs argument, object state = null, CancellationToken token = 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.
System.Threading.CancellationToken	token	Token to observe for cancellation of the request.

Returns

Type	Description
System.Threading.Tasks.Task<IAsyncReactiveQubject<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.