Class ReactiveClient

Exposes reactive processing client-side operations using a provider to perform service-side operations.

Inheritance

System.Object

ReactiveClientBase

ReactiveClient

Implements

IReactiveClient

Inherited Members

ReactiveClientBase.GetStreamFactory<TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArgs, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArgs, TInput, TOutput>(Uri)

ReactiveClientBase.GetStream<TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamCore<TInput, TOutput>(Uri)

ReactiveClientBase.GetObservable<T>(Uri)

ReactiveClientBase.GetObservableCore<T>(Uri)

ReactiveClientBase.GetObservable<TArgs, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArgs, TResult>(Uri)

ReactiveClientBase.GetObserver<T>(Uri)

ReactiveClientBase.GetObserverCore<T>(Uri)

ReactiveClientBase.GetObserver<TArgs, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArgs, TResult>(Uri)

ReactiveClientBase.GetSubscriptionFactory(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArgs>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArgs>(Uri)

ReactiveClientBase.GetSubscription(Uri)

ReactiveClientBase.GetSubscriptionCore(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Uri)

ReactiveClientBase.GetObservable<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Uri)

ReactiveClientBase.GetObservableCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Uri)

ReactiveClientBase.GetObserver<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Uri)

ReactiveClientBase.GetObserverCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TInput, TOutput>(Uri)

ReactiveClientBase.GetStreamFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TInput, TOutput>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>(Uri)

ReactiveClientBase.GetSubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>(Uri)

ReactiveClientBase.GetSubscriptionFactoryCore<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>(Uri)

ReactiveClientBase.Provider

Namespace: Reaqtor

Assembly: Reaqtor.Service.dll

Syntax

public class ReactiveClient : ReactiveClientBase, IReactiveClient

Constructors

ReactiveClient(IReactiveClientEngineProvider, IReactiveExpressionServices)

Creates a new reactive processing client using the specified client operations provider.

Declaration

public ReactiveClient(IReactiveClientEngineProvider provider, IReactiveExpressionServices expressionServices)

Parameters

Type	Name	Description
IReactiveClientEngineProvider	provider	Client operations provider.
IReactiveExpressionServices	expressionServices	Expression services object, used to perform expression tree manipulations.

Implements

IReactiveClient