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