peterhinch / micropython-mqtt

A 'resilient' asynchronous MQTT driver. Recovers from WiFi and broker outages.
MIT License
550 stars 117 forks source link

Added debug output, errors in the comments #28

Closed kevinkk525 closed 4 years ago

kevinkk525 commented 4 years ago

Sorry for the changes due to autopep.. makes it look like there are more changes.

peterhinch commented 4 years ago

Oh dear, I hadn't taken account of concurrent subscriptions. I think we need to use a similar approach to publications, of replacing self.suback with a set of expected PID's.

I'll push an update shortly. I'll only have time to verify basic functionality so it would be good if you could do concurrency testing: I'm currently working on fast_io to fix your https://github.com/micropython/micropython/issues/5242 and it's a pig to get right :)

kevinkk525 commented 4 years ago

No problem, I'll do the concurrency testing. Thanks for your efforts.