Interface IReactiveProxy

Interface for a client-side proxy for a full-blown reactive processing service.

Inherited Members

IReactiveClientProxy.GetStreamFactory<TInput, TOutput>(Uri)

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

IReactiveClientProxy.GetStream<TInput, TOutput>(Uri)

IReactiveClientProxy.GetObservable<T>(Uri)

IReactiveClientProxy.GetObservable<TArgs, TResult>(Uri)

IReactiveClientProxy.GetObserver<T>(Uri)

IReactiveClientProxy.GetObserver<TArgs, TResult>(Uri)

IReactiveClientProxy.GetSubscriptionFactory(Uri)

IReactiveClientProxy.GetSubscriptionFactory<TArgs>(Uri)

IReactiveClientProxy.GetSubscription(Uri)

IReactiveClientProxy.Provider

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

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

IReactiveDefinitionProxy.UndefineStreamFactoryAsync(Uri, CancellationToken)

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

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

IReactiveDefinitionProxy.UndefineObservableAsync(Uri, CancellationToken)

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

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

IReactiveDefinitionProxy.UndefineObserverAsync(Uri, CancellationToken)

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

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

IReactiveDefinitionProxy.UndefineSubscriptionFactoryAsync(Uri, CancellationToken)

IReactiveMetadataProxy.StreamFactories

IReactiveMetadataProxy.Streams

IReactiveMetadataProxy.Observables

IReactiveMetadataProxy.Observers

IReactiveMetadataProxy.SubscriptionFactories

IReactiveMetadataProxy.Subscriptions

Namespace: Reaqtor

Assembly: Reaqtor.Client.Model.dll

Syntax

public interface IReactiveProxy : IReactiveClientProxy, IReactiveDefinitionProxy, IReactiveMetadataProxy

Extension Methods

ReificationOperators.GetSourceObservable<T>(IReactiveProxy)

ReificationOperators.GetParameterizedSourceObservable<TParam, TResult>(IReactiveProxy)

ReificationOperators.GetSinkObserver<T>(IReactiveProxy)