paho.mqtt.python
paho.mqtt.python copied to clipboard
Cannot use loop_forever after having used loop_start/loop_stop
Currently loop_stop leaves self._thread_terminate = True
It should reset it to False after joining the worker thread:
self._thread_terminate = True
if threading.current_thread() != self._thread:
self._thread.join()
self._thread = None
self._thread_terminate = False