Interface IReactiveDefinitionEngineProvider

Interface for definitions operations of a reactive processing engine.

Namespace: Reaqtor

Assembly: Reaqtor.Engine.Contracts.dll

Syntax

public interface IReactiveDefinitionEngineProvider

Methods

DefineObservable(Uri, Expression, Object)

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

Declaration

void DefineObservable(Uri observableUri, Expression observable, object state)

Parameters

Type	Name	Description
System.Uri	observableUri	URI to identify the new observable.
System.Linq.Expressions.Expression	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.

DefineObserver(Uri, Expression, Object)

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

Declaration

void DefineObserver(Uri observerUri, Expression observer, object state)

Parameters

Type	Name	Description
System.Uri	observerUri	URI to identify the new observer.
System.Linq.Expressions.Expression	observer	Expression representing the observer creation.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

DefineStreamFactory(Uri, Expression, Object)

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

Declaration

void DefineStreamFactory(Uri streamFactoryUri, Expression streamFactory, object state)

Parameters

Type	Name	Description
System.Uri	streamFactoryUri	URI to identify the new stream factory.
System.Linq.Expressions.Expression	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.

DefineSubscriptionFactory(Uri, Expression, Object)

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

Declaration

void DefineSubscriptionFactory(Uri subscriptionFactoryUri, Expression subscriptionFactory, object state)

Parameters

Type	Name	Description
System.Uri	subscriptionFactoryUri	URI to identify the new subscription factory.
System.Linq.Expressions.Expression	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.

UndefineObservable(Uri)

Undefines the observable identified by the specified URI.

Declaration

void UndefineObservable(Uri observableUri)

Parameters

Type	Name	Description
System.Uri	observableUri	URI identifying the observable.

UndefineObserver(Uri)

Undefines the observer identified by the specified URI.

Declaration

void UndefineObserver(Uri observerUri)

Parameters

Type	Name	Description
System.Uri	observerUri	URI identifying the observer.

UndefineStreamFactory(Uri)

Undefines the stream factory identified by the specified URI.

Declaration

void UndefineStreamFactory(Uri streamFactoryUri)

Parameters

Type	Name	Description
System.Uri	streamFactoryUri	URI identifying the stream factory.

UndefineSubscriptionFactory(Uri)

Undefines the subscription factory identified by the specified URI.

Declaration

void UndefineSubscriptionFactory(Uri subscriptionFactoryUri)

Parameters

Type	Name	Description
System.Uri	subscriptionFactoryUri	URI identifying the subscription factory.