Interface IReactiveClient
Interface for the data operations on reactive processing services.
Namespace: Reaqtor
Assembly: Reaqtor.Service.Model.dll
Syntax
public interface IReactiveClientProperties
Provider
Gets the query provider that is used to build observables, observers, and streams.
Declaration
IReactiveQueryProvider Provider { get; }Property Value
| Type | Description |
|---|---|
| IReactiveQueryProvider |
Methods
GetObservable<T>(Uri)
Gets the observable with the specified URI.
Declaration
IReactiveQbservable<T> GetObservable<T>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the observable. |
Returns
| Type | Description |
|---|---|
| IReactiveQbservable<T> | Observable object that can be used to write queries against, or to receive data by subscribing to it using an observer. |
Type Parameters
| Name | Description |
|---|---|
| T | Type of the data produced by the observable. |
GetObservable<TArgs, TResult>(Uri)
Gets the parameterized observable with the specified URI.
Declaration
Func<TArgs, IReactiveQbservable<TResult>> GetObservable<TArgs, TResult>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the observable. |
Returns
| Type | Description |
|---|---|
| System.Func<TArgs, IReactiveQbservable<TResult>> | Observable object that can be used to write queries against, or to receive data by subscribing to it using an observer. |
Type Parameters
| Name | Description |
|---|---|
| TArgs | Type of the parameter passed to the observable. |
| TResult | Type of the data produced by the observable. |
GetObserver<T>(Uri)
Gets the observer with the specified URI.
Declaration
IReactiveQbserver<T> GetObserver<T>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the observer. |
Returns
| Type | Description |
|---|---|
| IReactiveQbserver<T> | Observer object that can be used to send data. |
Type Parameters
| Name | Description |
|---|---|
| T | Type of the data received by the observer. |
GetObserver<TArgs, TResult>(Uri)
Gets the parameterized observer with the specified URI.
Declaration
Func<TArgs, IReactiveQbserver<TResult>> GetObserver<TArgs, TResult>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the observer. |
Returns
| Type | Description |
|---|---|
| System.Func<TArgs, IReactiveQbserver<TResult>> | Observer object that can be used to send data. |
Type Parameters
| Name | Description |
|---|---|
| TArgs | Type of the parameter passed to the observer. |
| TResult | Type of the data received by the observer. |
GetStream<TInput, TOutput>(Uri)
Gets the stream, represented as a subject, with the specified URI.
Declaration
IReactiveQubject<TInput, TOutput> GetStream<TInput, TOutput>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the stream. |
Returns
| Type | Description |
|---|---|
| IReactiveQubject<TInput, TOutput> | Subject object that can be used to receive and publish data. |
Type Parameters
| Name | Description |
|---|---|
| TInput | Type of the data received by the subject. |
| TOutput | Type of the data produced by the subject. |
GetStreamFactory<TInput, TOutput>(Uri)
Gets the stream factory with the specified URI.
Declaration
IReactiveQubjectFactory<TInput, TOutput> GetStreamFactory<TInput, TOutput>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the stream factory. |
Returns
| Type | Description |
|---|---|
| IReactiveQubjectFactory<TInput, TOutput> | Stream factory that can be used to create streams, represented as subjects. |
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. |
GetStreamFactory<TArgs, TInput, TOutput>(Uri)
Gets the parameterized stream factory with the specified URI.
Declaration
IReactiveQubjectFactory<TInput, TOutput, TArgs> GetStreamFactory<TArgs, TInput, TOutput>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the stream factory. |
Returns
| Type | Description |
|---|---|
| IReactiveQubjectFactory<TInput, TOutput, TArgs> | Stream factory that can be used to create streams, represented as subjects. |
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. |
GetSubscription(Uri)
Gets the subscription with the specified URI.
Declaration
IReactiveQubscription GetSubscription(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the subscription. |
Returns
| Type | Description |
|---|---|
| IReactiveQubscription | Subscription object that can be used to dispose the subscription. |
GetSubscriptionFactory(Uri)
Gets the subscription factory with the specified URI.
Declaration
IReactiveQubscriptionFactory GetSubscriptionFactory(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the subscription factory. |
Returns
| Type | Description |
|---|---|
| IReactiveQubscriptionFactory | Subscription factory that can be used to create subscriptions. |
GetSubscriptionFactory<TArgs>(Uri)
Gets the parameterized subscription factory with the specified URI.
Declaration
IReactiveQubscriptionFactory<TArgs> GetSubscriptionFactory<TArgs>(Uri uri)Parameters
| Type | Name | Description |
|---|---|---|
| System.Uri | uri | URI identifying the subscription factory. |
Returns
| Type | Description |
|---|---|
| IReactiveQubscriptionFactory<TArgs> | Subscription factory that can be used to create subscriptions. |
Type Parameters
| Name | Description |
|---|---|
| TArgs | Type of the parameter passed to the subscription factory. |