Namespace Reaqtive
Classes
CompositeSubscription
Composite subscription that can hold a dynamic number of inner subscriptions.
ContextSwitchOperator<TParam, TResult>
Base class for operators that need a context switch between some arbitrary thread and a logical scheduler.
FaultObserver<TSource>
Observer implementation that throws an exception for each access.
GroupedMultiSubjectBase<TKey, TSource>
Base class for a subject that supports multiple observers and has a key.
HigherOrderInputStatefulOperator<TParam, TResult>
Base class for higher order query operator implementations. Operators are higher order when they receive inner subscribable sequences.
MultiSubject
Provides a set of methods to create multi-subjects.
MultiSubject<T>
Base class for multi-subjects.
MultiSubjectBase
Base implementation of the non-generic multi-subject.
MultiSubjectBase<T>
Base class for multi-subjects.
NopObserver<TSource>
Observer implementation that simply ignores any notifications it receives.
NopSubscription
A simple subscription that ignores any visitors.
ObservableExtensions
Provides conversions from System.IObservable<>.
Observer
Provides a set of methods to create observers.
Observer<T>
Base class for observers that can be visited as part of a subscription tree.
ObserverBase<T>
Base class for observer implementations.
Operator<TParam, TResult>
Base class for query operator implementations.
OperatorContext
Operator context.
SerialSubscription
Serial subscription that disposes an existing subscriptions upon reassigment.
SimpleSubject<T>
Subject with a single observer.
SingleAssignmentSubscription
Subscription that supports exactly one assignment of an inner subscription.
StableCompositeSubscription
Composite subscription that can hold a dynamic number of inner subscriptions.
StateChangedManager
Struct bundling all state management flags required to implement stateful artifacts.
StatefulMultiSubjectBase
Base implementation of the non-generic multi-subject, with support for checkpointing.
StatefulObserver<T>
Base class for stateful observer implementations, providing support to load and save observer state during checkpointing and recovery.
StatefulOperator<TParam, TResult>
Base class for stateful query operator implementations, providing support to load and save operator state during checkpointing and recovery.
StatefulUnaryOperator<TParam, TResult>
Base class for stateful query operator implementations, providing support to load and save operator state during checkpointing and recovery.
StateManager
Provides a set of methods to perform state management operations.
StaticCompositeSubscription
Composite subscription with a static set of inner subscriptions.
StaticCompositeSubscriptionBase
Base class for composite subscription with a static set of inner subscriptions.
Subscribable
Provides a set of query operators for subscribable sequences.
SubscribableBase<TResult>
Base class for subscribable sources.
SubscriptionInitializeVisitor
Visitor to initialize subscriptions.
SubscriptionStateVisitor
Visitor to act on operator state of a subscription.
SubscriptionVisitor
Base class for subscription visitors performing actions on each operator node in a subscription tree.
SubscriptionVisitor<T1>
Subscription visitor performing an action on each operator node in a subscription tree.
SubscriptionVisitor<T1, T2>
Subscription visitor performing actions on each operator node in a subscription tree.
SubscriptionVisitorBuilder<T1>
Builder for subscription visitors performing actions on each operator node in a subscription tree.
SubscriptionVisitorBuilder<T1, T2>
Builder for subscription visitors performing actions on each operator node in a subscription tree.
UnaryOperator<TParam, TResult>
Base class for query operator implementations.
VersionedMultiSubjectBase
Base implementation of the non-generic multi-subject, with support for versioning.
VersionedObserver<T>
Base class for observers with state versioning capabilities.
VersionedOperator<TParam, TResult>
Base class for operators with state versioning capabilities.
VersionedUnaryOperator<TParam, TResult>
Base class for operators with state versioning capabilities.
Interfaces
ICompositeSubscription
Represents a subscription that can hold a dynamic number of inner subscriptions.
IDependencyOperator
Represents an operator that's part of a dependency graph between related artifacts.
IDynamicMultiSubject
A multi-subject that can be typed at runtime.
IExecutionEnvironment
Represents the execution environment in which operators execute.
IFutureSubscription
Represents a subscription that can be assigned with an inner subscription.
IGroupedMultiSubject<TKey, TSource>
Represents a subject that supports multiple observers and has a key.
IGroupedSubscribable<TKey, TSource>
Represents a subscribable source with a grouping key.
IHigherOrderExecutionEnvironment
This interface supports hosting infrastructure for the operator library in a query engine.
IMonitorableQueue<T>
A queue with events for enqueue and dequeue operations for monitoring.
IMultiSubject
A non-generic multi-subject, useful to support streams of data that can be subscribed to with types that may change (i.e., due to versioning) over time.
IMultiSubject<T>
Represents a subject that supports multiple observers.
IMultiSubject<TInput, TOutput>
Represents a subject that supports multiple observers.
IOperator
Represents an operator used for event processing.
IOperatorContext
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.
IOperatorStateReader
Represents an operator state reader.
IOperatorStateReaderFactory
Represents a factory for operator state readers.
IOperatorStateWriter
Represents an operator state writer.
IOperatorStateWriterFactory
Represents a factory for operator state writers.
ISealable
Infrastructure.
IStatefulOperator
Stateful operators shold consider implementing this interface so they can participate in state persistence (checkpointing) and recovery.
Checkpoint sequence:
- SaveState
- OnStateSaved
Recovery sequence:
- SetContext
- LoadState
- Start
ISubscribable<T>
Represents a subscribable source.
ISubscription
Represents a subscription to a subscribable source.
ISubscriptionVisitor
Represents a subscription visitor that visits operator nodes.
ITransitioningOperator
Annotate operators with this interface to denote that existing subscriptions with this operator may need to transition from a stateless variant to a stateful one.
IUnaryOperator
Represents an operator with at most one child used for event processing.
IUnloadableOperator
Interface for operators that support unloading.
IVersioned
Represents artifacts that support versioning.