Class ReactiveMetadataProxyBase
Base class for reactive processing metadata discovery operations.
Implements
Namespace: Reaqtor
Assembly: Reaqtor.Client.Core.dll
Syntax
public abstract class ReactiveMetadataProxyBase : Object, IReactiveMetadataProxyConstructors
ReactiveMetadataProxyBase()
Creates a new instance of a reactive processing metadata discovery object.
Declaration
protected ReactiveMetadataProxyBase()Properties
Observables
Gets a queryable dictionary of observable definition objects.
Declaration
public IQueryableDictionary<Uri, IAsyncReactiveObservableDefinition> Observables { get; }Property Value
| Type | Description |
|---|---|
| IQueryableDictionary<System.Uri, IAsyncReactiveObservableDefinition> |
Observers
Gets a queryable dictionary of observer definition objects.
Declaration
public IQueryableDictionary<Uri, IAsyncReactiveObserverDefinition> Observers { get; }Property Value
| Type | Description |
|---|---|
| IQueryableDictionary<System.Uri, IAsyncReactiveObserverDefinition> |
StreamFactories
Gets a queryable dictionary of stream factory definition objects.
Declaration
public IQueryableDictionary<Uri, IAsyncReactiveStreamFactoryDefinition> StreamFactories { get; }Property Value
| Type | Description |
|---|---|
| IQueryableDictionary<System.Uri, IAsyncReactiveStreamFactoryDefinition> |
Streams
Gets a queryable dictionary of stream objects.
Declaration
public IQueryableDictionary<Uri, IAsyncReactiveStreamProcess> Streams { get; }Property Value
| Type | Description |
|---|---|
| IQueryableDictionary<System.Uri, IAsyncReactiveStreamProcess> |
SubscriptionFactories
Gets a queryable dictionary of subscription factory definition objects.
Declaration
public IQueryableDictionary<Uri, IAsyncReactiveSubscriptionFactoryDefinition> SubscriptionFactories { get; }Property Value
| Type | Description |
|---|---|
| IQueryableDictionary<System.Uri, IAsyncReactiveSubscriptionFactoryDefinition> |
Subscriptions
Gets a queryable dictionary of subscription objects.
Declaration
public IQueryableDictionary<Uri, IAsyncReactiveSubscriptionProcess> Subscriptions { get; }Property Value
| Type | Description |
|---|---|
| IQueryableDictionary<System.Uri, IAsyncReactiveSubscriptionProcess> |
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. |