Definition
Package: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Assembly: MessageHandler.Runtime.StreamProcessing.Pipeline.Reactive
Namespace: MessageHandler.Runtime.StreamProcessing
Class: ReactiveProcessing
Overloads
Method | Description |
---|---|
CompleteBatchesWith |
Complete batches with the given batch completion logic |
CompleteBatchesWith |
Complete batches with the given batch completion logic |
CompleteBatchesWith(this ReactiveProcessingConfiguration)
Complete batches with the given batch completion logic
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
The reactive processing configuration
Returns
MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
CompleteBatchesWith(this ReactiveProcessingConfiguration, T)
Complete batches with the given batch completion logic
Parameters
configuration: MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration
The reactive processing configuration
batcher: T
An instance of the batch completion type
Returns
MessageHandler.Runtime.StreamProcessing.ReactiveProcessingConfiguration