Interface IReactiveDefinition

Interface for the definition operations on reactive processing services.

Namespace: Reaqtor

Assembly: Reaqtor.Service.Model.dll

Syntax

public interface IReactiveDefinition

Methods

DefineObservable<T>(Uri, IReactiveQbservable<T>, Object)

Defines an observable identified by the specified URI.

Declaration

void DefineObservable<T>(Uri uri, IReactiveQbservable<T> observable, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observable.
IReactiveQbservable<T>	observable	Observable to be defined.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

Type Parameters

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

DefineObservable<TArgs, TResult>(Uri, Expression<Func<TArgs, IReactiveQbservable<TResult>>>, Object)

Defines a parameterized observable identified by the specified URI.

Declaration

void DefineObservable<TArgs, TResult>(Uri uri, Expression<Func<TArgs, IReactiveQbservable<TResult>>> observable, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observable.
System.Linq.Expressions.Expression<System.Func<TArgs, IReactiveQbservable<TResult>>>	observable	Observable to be defined.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

Type Parameters

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

DefineObserver<T>(Uri, IReactiveQbserver<T>, Object)

Defines an observer identified by the specified URI.

Declaration

void DefineObserver<T>(Uri uri, IReactiveQbserver<T> observer, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observer.
IReactiveQbserver<T>	observer	Observer to be defined.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

Type Parameters

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

DefineObserver<TArgs, TResult>(Uri, Expression<Func<TArgs, IReactiveQbserver<TResult>>>, Object)

Defines a parameterized observer identified by the specified URI.

Declaration

void DefineObserver<TArgs, TResult>(Uri uri, Expression<Func<TArgs, IReactiveQbserver<TResult>>> observer, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the observer.
System.Linq.Expressions.Expression<System.Func<TArgs, IReactiveQbserver<TResult>>>	observer	Observer to be defined.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

Type Parameters

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

DefineStreamFactory<TInput, TOutput>(Uri, IReactiveQubjectFactory<TInput, TOutput>, Object)

Defines a stream factory identified by the specified URI.

Declaration

void DefineStreamFactory<TInput, TOutput>(Uri uri, IReactiveQubjectFactory<TInput, TOutput> streamFactory, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the stream factory.
IReactiveQubjectFactory<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.

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.

DefineStreamFactory<TArgs, TInput, TOutput>(Uri, IReactiveQubjectFactory<TInput, TOutput, TArgs>, Object)

Defines a parameterized stream factory identified by the specified URI.

Declaration

void DefineStreamFactory<TArgs, TInput, TOutput>(Uri uri, IReactiveQubjectFactory<TInput, TOutput, TArgs> streamFactory, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the stream factory.
IReactiveQubjectFactory<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.

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.

DefineSubscriptionFactory(Uri, IReactiveQubscriptionFactory, Object)

Defines a subscription factory identified by the specified URI.

Declaration

void DefineSubscriptionFactory(Uri uri, IReactiveQubscriptionFactory subscriptionFactory, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the subscription factory.
IReactiveQubscriptionFactory	subscriptionFactory	Subscription factory to be defined.
System.Object	state	Additional metadata to associate with the artifact. Implementations can interpret this value, or ignore it.

DefineSubscriptionFactory<TArgs>(Uri, IReactiveQubscriptionFactory<TArgs>, Object)

Defines a parameterized subscription factory identified by the specified URI.

Declaration

void DefineSubscriptionFactory<TArgs>(Uri uri, IReactiveQubscriptionFactory<TArgs> subscriptionFactory, object state = null)

Parameters

Type	Name	Description
System.Uri	uri	URI identifying the subscription factory.
IReactiveQubscriptionFactory<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.

Type Parameters

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

UndefineObservable(Uri)

Undefines the observable identified by the specified URI.

Declaration

void UndefineObservable(Uri uri)

Parameters

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

UndefineObserver(Uri)

Undefines the observer identified by the specified URI.

Declaration

void UndefineObserver(Uri uri)

Parameters

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

UndefineStreamFactory(Uri)

Undefines the stream factory identified by the specified URI.

Declaration

void UndefineStreamFactory(Uri uri)

Parameters

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

UndefineSubscriptionFactory(Uri)

Undefines the subscription factory identified by the specified URI.

Declaration

void UndefineSubscriptionFactory(Uri uri)

Parameters

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