Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Assembly: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Namespace: MessageHandler.Runtime.StreamProcessing
Class: ReactiveProcessing
EnableReactiveProcessing(this PipelineConfiguration, Action)
Enable reactive processing
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.PipelineConfiguration
The stream processing pipeline
callback: System.Action
A callback to configure the reactive processing logic
Returns
MessageHandler.Runtime.StreamProcessing.PipelineConfiguration