search

AtherEnergy / rumqtt

Pure rust mqtt cilent
The Unlicense
203 stars 72 forks source link

Fix Issue #166 #180

Open baer-devl opened 4 years ago

baer-devl commented 4 years ago

Create an unbounded crossbeam_channel by default. For bounded crossbeam_channel use the 'set_notification_channel_capacity' to a value of choice.

This should fix the issue #166

baer-devl commented 4 years ago

All tests are passed as well!