Interface IReactiveClientEngineProvider

Interface for client operations of a reactive processing engine.

Namespace: Reaqtor

Assembly: Reaqtor.Engine.Contracts.dll

Syntax

public interface IReactiveClientEngineProvider

Methods

CreateStream(Uri, Expression, Object)

Creates a new stream using the specified expression tree representation.

Declaration

void CreateStream(Uri streamUri, Expression stream, object state)

Parameters

Type	Name	Description
System.Uri	streamUri	URI to identify the new stream.
System.Linq.Expressions.Expression	stream	Expression representing the stream creation. (E.g. an invocation of a known stream factory.)
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

CreateSubscription(Uri, Expression, Object)

Creates a new subscription using the specified expression tree representation.

Declaration

void CreateSubscription(Uri subscriptionUri, Expression subscription, object state)

Parameters

Type	Name	Description
System.Uri	subscriptionUri	URI to identify the new subscription.
System.Linq.Expressions.Expression	subscription	Expression representing the subscription creation. (E.g. an invocation of the subscription operation on an observable.)
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

DeleteStream(Uri)

Deletes the stream identified by the specified URI.

Declaration

void DeleteStream(Uri streamUri)

Parameters

Type	Name	Description
System.Uri	streamUri	URI of the stream to delete.

DeleteSubscription(Uri)

Deletes the subscription identified by the specified URI.

Declaration

void DeleteSubscription(Uri subscriptionUri)

Parameters

Type	Name	Description
System.Uri	subscriptionUri	URI of the subscription to delete.

GetObserver<T>(Uri)

Gets an observer to send notifications to.

Declaration

IReactiveObserver<T> GetObserver<T>(Uri observerUri)

Parameters

Type	Name	Description
System.Uri	observerUri	URI of the observer to send the notification to.

Returns

Type	Description
IReactiveObserver<T>	Observer that can be used to send notifications to.

Type Parameters

Name	Description
T	Type of the value to send to the observer.