Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Classes in this package
Class | Description |
---|---|
ReactiveProcessing | Extension methods which allow to configure the runtime for reactive stream processing |
ActionableContext | An actionable context, representing a message that can be acted upon |
All | A standing query builder which returns all messages. |
Interfaces in this package
Interface | Description |
---|---|
IAction | Interface implemented by class that take action on events returned by a standing query |
ICompleteBatches | Interface implemented by class that complete batches of messages |
IStandingQueryBuilder | Interface implemented by classes which build standing queries |