Interface IReactiveDefinitionProxy

Interface for a client-side proxy for the definition operations on reactive processing services.

Namespace: Reaqtor

Assembly: Reaqtor.Client.Model.dll

Syntax

public interface IReactiveDefinitionProxy

Methods

DefineObservableAsync<T>(Uri, IAsyncReactiveQbservable<T>, Object, CancellationToken)

Defines an observable identified by the specified URI.

Declaration

Task DefineObservableAsync<T>(Uri uri, IAsyncReactiveQbservable<T> observable, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observable.
IAsyncReactiveQbservable<T>	observable	Observable to be defined.
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	Task to await the completion of the observable definition.

Type Parameters

Name	Description
T	Type of the data produced by the observable.

DefineObservableAsync<TArgs, TResult>(Uri, Expression<Func<TArgs, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

Defines a parameterized observable identified by the specified URI.

Declaration

Task DefineObservableAsync<TArgs, TResult>(Uri uri, Expression<Func<TArgs, IAsyncReactiveQbservable<TResult>>> observable, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observable.
System.Linq.Expressions.Expression<System.Func<TArgs, IAsyncReactiveQbservable<TResult>>>	observable	Observable to be defined.
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	Task to await the completion of the observable definition.

Type Parameters

Name	Description
TArgs	Type of the parameter passed to the observable.
TResult	Type of the data produced by the observable.

DefineObserverAsync<T>(Uri, IAsyncReactiveQbserver<T>, Object, CancellationToken)

Defines an observer identified by the specified URI.

Declaration

Task DefineObserverAsync<T>(Uri uri, IAsyncReactiveQbserver<T> observer, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observer.
IAsyncReactiveQbserver<T>	observer	Observer to be defined.
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	Task to await the completion of the observer definition.

Type Parameters

Name	Description
T	Type of the data received by the observer.

DefineObserverAsync<TArgs, TResult>(Uri, Expression<Func<TArgs, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

Defines a parameterized observer identified by the specified URI.

Declaration

Task DefineObserverAsync<TArgs, TResult>(Uri uri, Expression<Func<TArgs, IAsyncReactiveQbserver<TResult>>> observer, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observer.
System.Linq.Expressions.Expression<System.Func<TArgs, IAsyncReactiveQbserver<TResult>>>	observer	Observer to be defined.
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	Task to await the completion of the observer definition.

Type Parameters

Name	Description
TArgs	Type of the parameter passed to the observer.
TResult	Type of the data received by the observer.

DefineStreamFactoryAsync<TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput>, Object, CancellationToken)

Defines a stream factory identified by the specified URI.

Declaration

Task DefineStreamFactoryAsync<TInput, TOutput>(Uri uri, IAsyncReactiveQubjectFactory<TInput, TOutput> streamFactory, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the stream factory.
IAsyncReactiveQubjectFactory<TInput, TOutput>	streamFactory	Stream factory to be defined.
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	Task to await the completion of the stream factory definition.

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.

DefineStreamFactoryAsync<TArgs, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs>, Object, CancellationToken)

Defines a parameterized stream factory identified by the specified URI.

Declaration

Task DefineStreamFactoryAsync<TArgs, TInput, TOutput>(Uri uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs> streamFactory, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the stream factory.
IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs>	streamFactory	Stream factory to be defined.
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	Task to await the completion of the stream factory definition.

Type Parameters

Name	Description
TArgs	Type of the parameter passed to the stream factory.
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.

DefineSubscriptionFactoryAsync(Uri, IAsyncReactiveQubscriptionFactory, Object, CancellationToken)

Defines a subscription factory identified by the specified URI.

Declaration

Task DefineSubscriptionFactoryAsync(Uri uri, IAsyncReactiveQubscriptionFactory subscriptionFactory, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the subscription factory.
IAsyncReactiveQubscriptionFactory	subscriptionFactory	Subscription factory to be defined.
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	Task to await the completion of the subscription factory definition.

DefineSubscriptionFactoryAsync<TArgs>(Uri, IAsyncReactiveQubscriptionFactory<TArgs>, Object, CancellationToken)

Defines a parameterized subscription factory identified by the specified URI.

Declaration

Task DefineSubscriptionFactoryAsync<TArgs>(Uri uri, IAsyncReactiveQubscriptionFactory<TArgs> subscriptionFactory, object state = null, CancellationToken token = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the subscription factory.
IAsyncReactiveQubscriptionFactory<TArgs>	subscriptionFactory	Subscription factory to be defined.
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	Task to await the completion of the subscription factory definition.

Type Parameters

Name	Description
TArgs	Type of the parameter passed to the subscription factory.

UndefineObservableAsync(Uri, CancellationToken)

Undefines the observable identified by the specified URI.

Declaration

Task UndefineObservableAsync(Uri uri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observable.
System.Threading.CancellationToken	token	Token to observe for cancellation of the request.

Returns

Type	Description
System.Threading.Tasks.Task	Task to await the completion of the observable undefinition.

UndefineObserverAsync(Uri, CancellationToken)

Undefines the observer identified by the specified URI.

Declaration

Task UndefineObserverAsync(Uri uri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observer.
System.Threading.CancellationToken	token	Token to observe for cancellation of the request.

Returns

Type	Description
System.Threading.Tasks.Task	Task to await the completion of the observer undefinition.

UndefineStreamFactoryAsync(Uri, CancellationToken)

Undefines the stream factory identified by the specified URI.

Declaration

Task UndefineStreamFactoryAsync(Uri uri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the stream factory.
System.Threading.CancellationToken	token	Token to observe for cancellation of the request.

Returns

Type	Description
System.Threading.Tasks.Task	Task to await the completion of the stream factory undefinition.

UndefineSubscriptionFactoryAsync(Uri, CancellationToken)

Undefines the subscription factory identified by the specified URI.

Declaration

Task UndefineSubscriptionFactoryAsync(Uri uri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the subscription factory.
System.Threading.CancellationToken	token	Token to observe for cancellation of the request.

Returns

Type	Description
System.Threading.Tasks.Task	Task to await the completion of the subscription factory undefinition.