This commit is contained in:
vshijiav 2025-10-31 08:16:14 +00:00 committed by GitHub
commit 0f1a67cc5d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

@ -589,6 +589,13 @@ class _MipsClient(ABC):
def __mqtt_loop_handler(self) -> None:
try:
# If the main loop is closed, stop the internal loop immediately
if self.main_loop.is_closed():
self.log_debug(
'The main loop is closed, stop the internal loop.')
if not self._internal_loop.is_closed():
self._internal_loop.stop()
return
if self._mqtt:
self._mqtt.loop_read()
if self._mqtt: