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