rumqtt
rumqtt copied to clipboard
Implement `Broker::spawn` method
The Broker::spawn
can be used to only spawn the broker tasks without the console interface of the broker.
This PR seems to be much more than just spawning the broker. This enables customization of spawn's runtime. Can you let me know the motivation behind this? Are you facing any problem with tokio's current thread runtime (per listener)?
I already have a tokio runtime in my application and I want to spawn all tasks within this runtime. So the balancing of the different tasks could be managed by a single instance of the runtime (which may increase performance).