Interface IReactive

Interface for a full-blown reactive processing service.

Inherited Members

IReactiveClient.GetStreamFactory<TInput, TOutput>(Uri)

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

IReactiveClient.GetStream<TInput, TOutput>(Uri)

IReactiveClient.GetObservable<T>(Uri)

IReactiveClient.GetObservable<TArgs, TResult>(Uri)

IReactiveClient.GetObserver<T>(Uri)

IReactiveClient.GetObserver<TArgs, TResult>(Uri)

IReactiveClient.GetSubscriptionFactory(Uri)

IReactiveClient.GetSubscriptionFactory<TArgs>(Uri)

IReactiveClient.GetSubscription(Uri)

IReactiveClient.Provider

IReactiveDefinition.DefineStreamFactory<TInput, TOutput>(Uri, IReactiveQubjectFactory<TInput, TOutput>, Object)

IReactiveDefinition.DefineStreamFactory<TArgs, TInput, TOutput>(Uri, IReactiveQubjectFactory<TInput, TOutput, TArgs>, Object)

IReactiveDefinition.UndefineStreamFactory(Uri)

IReactiveDefinition.DefineObservable<T>(Uri, IReactiveQbservable<T>, Object)

IReactiveDefinition.DefineObservable<TArgs, TResult>(Uri, Expression<Func<TArgs, IReactiveQbservable<TResult>>>, Object)

IReactiveDefinition.UndefineObservable(Uri)

IReactiveDefinition.DefineObserver<T>(Uri, IReactiveQbserver<T>, Object)

IReactiveDefinition.DefineObserver<TArgs, TResult>(Uri, Expression<Func<TArgs, IReactiveQbserver<TResult>>>, Object)

IReactiveDefinition.UndefineObserver(Uri)

IReactiveDefinition.DefineSubscriptionFactory(Uri, IReactiveQubscriptionFactory, Object)

IReactiveDefinition.DefineSubscriptionFactory<TArgs>(Uri, IReactiveQubscriptionFactory<TArgs>, Object)

IReactiveDefinition.UndefineSubscriptionFactory(Uri)

IReactiveMetadata.StreamFactories

IReactiveMetadata.Streams

IReactiveMetadata.Observables

IReactiveMetadata.Observers

IReactiveMetadata.SubscriptionFactories

IReactiveMetadata.Subscriptions

Namespace: Reaqtor

Assembly: Reaqtor.Service.Model.dll

Syntax

public interface IReactive : IReactiveClient, IReactiveDefinition, IReactiveMetadata