rumqtt
rumqtt copied to clipboard
rumqttc | Unbounded channel
At the moment, the only way to construct a client is to provide a fixed client capacity. A client with unlimited channel capacity would be desirable.
Furthermore, the pure implementation is already available because rumqttc
is built on flume
. The client/event_loop has to be refactored in order to enable support for both bounded and unbounded channels.
Let me know what you think 🤯