run

open override fun run()

Starts the dispatcher by subscribing to the message flux.

Groups messages by key for parallel processing and handles each group. The result is subscribed to this dispatcher for error handling.