Class ReactiveMetadataBase

Base class for reactive processing metadata discovery operations.

Inheritance

System.Object

ReactiveMetadataBase

ReactiveMetadata

Implements

IReactiveMetadata

Namespace: Reaqtor

Assembly: Reaqtor.Service.Core.dll

Syntax

public abstract class ReactiveMetadataBase : Object, IReactiveMetadata

Constructors

ReactiveMetadataBase()

Creates a new instance of a reactive processing metadata discovery object.

Declaration

protected ReactiveMetadataBase()

Properties

Observables

Gets a queryable dictionary of observable definition objects.

Declaration

public virtual IQueryableDictionary<Uri, IReactiveObservableDefinition> Observables { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IReactiveObservableDefinition>

Observers

Gets a queryable dictionary of observer definition objects.

Declaration

public virtual IQueryableDictionary<Uri, IReactiveObserverDefinition> Observers { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IReactiveObserverDefinition>

StreamFactories

Gets a queryable dictionary of stream factory definition objects.

Declaration

public virtual IQueryableDictionary<Uri, IReactiveStreamFactoryDefinition> StreamFactories { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IReactiveStreamFactoryDefinition>

Streams

Gets a queryable dictionary of stream objects.

Declaration

public virtual IQueryableDictionary<Uri, IReactiveStreamProcess> Streams { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IReactiveStreamProcess>

SubscriptionFactories

Gets a queryable dictionary of subscription factory definition objects.

Declaration

public virtual IQueryableDictionary<Uri, IReactiveSubscriptionFactoryDefinition> SubscriptionFactories { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IReactiveSubscriptionFactoryDefinition>

Subscriptions

Gets a queryable dictionary of subscription objects.

Declaration

public virtual IQueryableDictionary<Uri, IReactiveSubscriptionProcess> Subscriptions { get; }

Property Value

Type	Description
IQueryableDictionary<System.Uri, IReactiveSubscriptionProcess>

Methods

Execute<TResult>(Expression)

Executes the specified expression.

Declaration

protected abstract TResult Execute<TResult>(Expression expression)

Parameters

Type	Name	Description
System.Linq.Expressions.Expression	expression	Expression to execute.

Returns

Type	Description
TResult	Result of executing the expression.

Type Parameters

Name	Description
TResult	Result type of the expression.

Implements

IReactiveMetadata