Namespace Reaqtor.Reactive

Classes

GroupedMultiSubjectProxy<TKey, TSource>

A proxy for group subjects.

HigherOrderExecutionEnvironment

This interface supports hosting infrastructure for the operator library in a query engine.

HigherOrderSubscriptionFailedException

Exception representing failures in higher order subscriptions.

MultiSubjectProxy<TInput, TOutput>

A proxy for subjects.

Interfaces

This is the context provided to each reactive operator after it is instantiated. Operators must interact with the environment only through this context to ensure that they can be properly hosted inside QueryEngines.