The stream processing runtime, helps you to build event generators, stream processors, and transient reactions.
Configuring stream processing
To set up stream processing, you need the MessageHandler.Runtime.StreamProcessing extensions package.
PM> Install-Package MessageHandler.Runtime.StreamProcessing
Integrating into an existing handler runtime configuration
The most common scenario is to add stream processing as a capability to a host integrated handler runtime.
To make this easy, there is an extension method called StreamProcessingPipeline.
runtimeConfiguration.StreamProcessingPipeline(pipeline =>
{
});
Each invocation of this method will result in a new pipeline instance.
Once you have a pipeline configuration instance, you can start to configure it.