This commit is contained in:
vshijiav 2025-10-30 09:15:00 -07:00 committed by GitHub
parent c04fa542a3
commit e70bef33e4
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194

View File

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