Interface IAsyncReactiveObservableDefinition
Interface representing an observable definition in a reactive processing service.
Inherited Members
Namespace: Reaqtor.Metadata
Assembly: Reaqtor.Metadata.Model.dll
Syntax
public interface IAsyncReactiveObservableDefinition : IAsyncReactiveDefinedResource, IAsyncReactiveResource, IKnownResource, IExpressibleMethods
ToObservable<T>()
Gets the observable defined by the definition.
Declaration
IAsyncReactiveQbservable<T> ToObservable<T>()Returns
| Type | Description |
|---|---|
| IAsyncReactiveQbservable<T> | Representation of the observable defined by the definition. |
Type Parameters
| Name | Description |
|---|---|
| T | Type of the data produced by the observable. |
Remarks
This method can be used in isolation from the client library. It's allowed to return an object that encapsulates the definition using an expression tree, to be used for composition and delegation to other systems. The object does not have to provide data operations, as is expected from the client library proxy objects.
ToObservable<TArgs, TResult>()
Gets the parameterized observable defined by the definition.
Declaration
Func<TArgs, IAsyncReactiveQbservable<TResult>> ToObservable<TArgs, TResult>()Returns
| Type | Description |
|---|---|
| System.Func<TArgs, IAsyncReactiveQbservable<TResult>> | Representation of the parameterized observable defined by the definition. |
Type Parameters
| Name | Description |
|---|---|
| TArgs | Type of the parameter passed to the observable. |
| TResult | Type of the data produced by the observable. |
Remarks
This method can be used in isolation from the client library. It's allowed to return an object that encapsulates the definition using an expression tree, to be used for composition and delegation to other systems. The object does not have to provide data operations, as is expected from the client library proxy objects.