Class ReactiveClientContext

Base class for reactive processing service proxy context with client-side, definition, and metadata operations.

Inheritance

System.Object

ReactiveClientContextBase

ReactiveClientContext

ReificationClientContext

Implements

IReactiveProxy

IReactiveClientProxy

IReactiveDefinitionProxy

IReactiveMetadataProxy

Inherited Members

ReactiveClientContextBase.GetStreamFactory<TInput, TOutput>(Uri)

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

ReactiveClientContextBase.GetStream<TInput, TOutput>(Uri)

ReactiveClientContextBase.GetObservable<T>(Uri)

ReactiveClientContextBase.GetObservable<TArgs, TResult>(Uri)

ReactiveClientContextBase.GetObserver<T>(Uri)

ReactiveClientContextBase.GetObserver<TArgs, TResult>(Uri)

ReactiveClientContextBase.GetSubscriptionFactory(Uri)

ReactiveClientContextBase.GetSubscriptionFactory<TArgs>(Uri)

ReactiveClientContextBase.GetSubscription(Uri)

ReactiveClientContextBase.DefineStreamFactoryAsync<TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArgs, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArgs>, Object, CancellationToken)

ReactiveClientContextBase.UndefineStreamFactoryAsync(Uri, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<T>(Uri, IAsyncReactiveQbservable<T>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArgs, TResult>(Uri, Expression<Func<TArgs, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.UndefineObservableAsync(Uri, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<T>(Uri, IAsyncReactiveQbserver<T>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArgs, TResult>(Uri, Expression<Func<TArgs, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.UndefineObserverAsync(Uri, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync(Uri, IAsyncReactiveQubscriptionFactory, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArgs>(Uri, IAsyncReactiveQubscriptionFactory<TArgs>, Object, CancellationToken)

ReactiveClientContextBase.UndefineSubscriptionFactoryAsync(Uri, CancellationToken)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

ReactiveClientContextBase.GetSubscriptionFactory<TArg1, TArg2>(Uri)

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

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

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

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

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

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

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

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

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

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

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

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

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

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>, Object, CancellationToken)

ReactiveClientContextBase.DefineStreamFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TInput, TOutput>(Uri, IAsyncReactiveQubjectFactory<TInput, TOutput, TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TResult>(Uri, Expression<Func<TArg1, TArg2, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObservableAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, IAsyncReactiveQbservable<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TResult>(Uri, Expression<Func<TArg1, TArg2, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineObserverAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, TResult>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, IAsyncReactiveQbserver<TResult>>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1>(Uri, Expression<Func<TArg1, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2>(Uri, Expression<Func<TArg1, TArg2, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3>(Uri, Expression<Func<TArg1, TArg2, TArg3, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>(Uri, IAsyncReactiveQubscriptionFactory<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>, Object, CancellationToken)

ReactiveClientContextBase.DefineSubscriptionFactoryAsync<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15>(Uri, Expression<Func<TArg1, TArg2, TArg3, TArg4, TArg5, TArg6, TArg7, TArg8, TArg9, TArg10, TArg11, TArg12, TArg13, TArg14, TArg15, IAsyncReactiveQubscription>>, Object, CancellationToken)

ReactiveClientContextBase.Provider

ReactiveClientContextBase.StreamFactories

ReactiveClientContextBase.Streams

ReactiveClientContextBase.Observables

ReactiveClientContextBase.Observers

ReactiveClientContextBase.SubscriptionFactories

ReactiveClientContextBase.Subscriptions

Namespace: Reaqtor

Assembly: Reaqtor.Client.dll

Syntax

public abstract class ReactiveClientContext : ReactiveClientContextBase, IReactiveProxy, IReactiveClientProxy, IReactiveDefinitionProxy, IReactiveMetadataProxy

Constructors

ReactiveClientContext(IReactiveExpressionServices, IReactiveClientServiceProvider, IReactiveDefinitionServiceProvider, IReactiveMetadataServiceProvider)

Creates a new reactive processing context using the specified services and with default proxy objects.

Declaration

protected ReactiveClientContext(IReactiveExpressionServices expressionServices, IReactiveClientServiceProvider clientService, IReactiveDefinitionServiceProvider definitionService, IReactiveMetadataServiceProvider metadataService)

Parameters

Type	Name	Description
IReactiveExpressionServices	expressionServices	Expression tree services.
IReactiveClientServiceProvider	clientService	Client-side operation services.
IReactiveDefinitionServiceProvider	definitionService	Definition operation services.
IReactiveMetadataServiceProvider	metadataService	Metadata services.

ReactiveClientContext(IReactiveExpressionServices, IReactiveServiceProvider)

Creates a new reactive processing context using the specified services.

Declaration

protected ReactiveClientContext(IReactiveExpressionServices expressionServices, IReactiveServiceProvider clientServiceProvider)

Parameters

Type	Name	Description
IReactiveExpressionServices	expressionServices	Expression tree services.
IReactiveServiceProvider	clientServiceProvider	Client/service provider.

ReactiveClientContext(IReactiveExpressionServices, ReactiveClientProxy, ReactiveDefinitionProxy, ReactiveMetadataProxy)

Creates a new reactive processing context using the specified proxy objects.

Declaration

protected ReactiveClientContext(IReactiveExpressionServices expressionServices, ReactiveClientProxy clientProxy, ReactiveDefinitionProxy definitionProxy, ReactiveMetadataProxy metadataProxy)

Parameters

Type	Name	Description
IReactiveExpressionServices	expressionServices	Expression tree services.
ReactiveClientProxy	clientProxy	Client-side operation proxy.
ReactiveDefinitionProxy	definitionProxy	Definition operation proxy.
ReactiveMetadataProxy	metadataProxy	Metadata service proxy.

Properties

Client

Gets the client-side operations interface for the reactive processing service.

Declaration

protected override ReactiveClientProxyBase Client { get; }

Property Value

Type	Description
ReactiveClientProxyBase

Overrides

ReactiveClientContextBase.Client

Definition

Gets the definition operations interface for the reactive processing service.

Declaration

protected override ReactiveDefinitionProxyBase Definition { get; }

Property Value

Type	Description
ReactiveDefinitionProxyBase

Overrides

ReactiveClientContextBase.Definition

Metadata

Gets the metadata operations interface for the reactive processing service.

Declaration

protected override ReactiveMetadataProxyBase Metadata { get; }

Property Value

Type	Description
ReactiveMetadataProxyBase

Overrides

ReactiveClientContextBase.Metadata

Implements

IReactiveProxy

IReactiveClientProxy

IReactiveDefinitionProxy

IReactiveMetadataProxy