Interface IReactiveDefinitionServiceProvider<TExpression>

Interface for definitions operations of a reactive processing service.

Namespace: Reaqtor

Assembly: Reaqtor.Service.Contracts.dll

Syntax

public interface IReactiveDefinitionServiceProvider<TExpression>

Type Parameters

Name	Description
TExpression	Type used for expression tree representation.

Methods

DefineObservableAsync(Uri, TExpression, Object, CancellationToken)

Defines an observable using the specified expression tree representation. The observable can be parameterized by specifying a lambda expression.

Declaration

Task DefineObservableAsync(Uri observableUri, TExpression observable, object state, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	observableUri	URI to identify the new observable.
TExpression	observable	Expression representing the observable creation. (E.g. using composition of LINQ query operators.)
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.

DefineObserverAsync(Uri, TExpression, Object, CancellationToken)

Defines an observer using the specified expression tree representation. The observer can be parameterized by specifying a lambda expression.

Declaration

Task DefineObserverAsync(Uri observerUri, TExpression observer, object state, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	observerUri	URI to identify the new observer.
TExpression	observer	Expression representing the observer creation.
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.

DefineStreamFactoryAsync(Uri, TExpression, Object, CancellationToken)

Defines a stream factory using the specified expression tree representation. The stream factory can be parameterized by specifying a lambda expression.

Declaration

Task DefineStreamFactoryAsync(Uri streamFactoryUri, TExpression streamFactory, object state, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	streamFactoryUri	URI to identify the new stream factory.
TExpression	streamFactory	Expression representing the stream factory creation.
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.

DefineSubscriptionFactoryAsync(Uri, TExpression, Object, CancellationToken)

Defines a subscription factory using the specified expression tree representation. The subscription factory can be parameterized by specifying a lambda expression.

Declaration

Task DefineSubscriptionFactoryAsync(Uri subscriptionFactoryUri, TExpression subscriptionFactory, object state, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	subscriptionFactoryUri	URI to identify the new subscription factory.
TExpression	subscriptionFactory	Expression representing the subscription factory creation.
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.

UndefineObservableAsync(Uri, CancellationToken)

Undefines the observable identified by the specified URI.

Declaration

Task UndefineObservableAsync(Uri observableUri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	observableUri	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 observerUri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	observerUri	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 streamFactoryUri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	streamFactoryUri	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 subscriptionFactoryUri, CancellationToken token)

Parameters

Type	Name	Description
System.Uri	subscriptionFactoryUri	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.