Interface IReactiveClientProxy

Interface for a client-side proxy for the data operations on reactive processing services.

Namespace: Reaqtor

Assembly: Reaqtor.Client.Model.dll

Syntax

public interface IReactiveClientProxy

Properties

Provider

Gets the query provider that is used to build observables, observers, and streams.

Declaration

IAsyncReactiveQueryProvider Provider { get; }

Property Value

Type	Description
IAsyncReactiveQueryProvider

Methods

GetObservable<T>(Uri)

Gets the observable with the specified URI.

Declaration

IAsyncReactiveQbservable<T> GetObservable<T>(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQbservable<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, IAsyncReactiveQbservable<TResult>> GetObservable<TArgs, TResult>(Uri uri)

Parameters

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

Returns

Type	Description
System.Func<TArgs, IAsyncReactiveQbservable<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

IAsyncReactiveQbserver<T> GetObserver<T>(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQbserver<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, IAsyncReactiveQbserver<TResult>> GetObserver<TArgs, TResult>(Uri uri)

Parameters

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

Returns

Type	Description
System.Func<TArgs, IAsyncReactiveQbserver<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

IAsyncReactiveQubject<TInput, TOutput> GetStream<TInput, TOutput>(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQubject<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

IAsyncReactiveQubjectFactory<TInput, TOutput> GetStreamFactory<TInput, TOutput>(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQubjectFactory<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

IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs> GetStreamFactory<TArgs, TInput, TOutput>(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQubjectFactory<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

IAsyncReactiveQubscription GetSubscription(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQubscription	Subscription object that can be used to dispose the subscription.

GetSubscriptionFactory(Uri)

Gets the subscription factory with the specified URI.

Declaration

IAsyncReactiveQubscriptionFactory GetSubscriptionFactory(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQubscriptionFactory	Subscription factory that can be used to create subscriptions.

GetSubscriptionFactory<TArgs>(Uri)

Gets the parameterized subscription factory with the specified URI.

Declaration

IAsyncReactiveQubscriptionFactory<TArgs> GetSubscriptionFactory<TArgs>(Uri uri)

Parameters

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

Returns

Type	Description
IAsyncReactiveQubscriptionFactory<TArgs>	Subscription factory that can be used to create subscriptions.

Type Parameters

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