fix: release the mqtt thread on release

Author: allenporter

roborock/cloud_api.py

@@ -74,6 +74,12 @@ def __init__(self, user_data: UserData, device_info: DeviceData, queue_timeout:
         self._waiting_queue: dict[int, RoborockFuture] = {}
         self._mutex = Lock()
 
+    async def async_release(self) -> None:
+        """Release the MQTT client."""
+        await super().async_release()
+        if self._mqtt_client:
+            await self.event_loop.run_in_executor(None, self._mqtt_client.loop_stop)
+
     def _mqtt_on_connect(self, *args, **kwargs):
         _, __, ___, rc, ____ = args
         connection_queue = self._waiting_queue.get(CONNECT_REQUEST_ID)
@@ -157,7 +163,6 @@ async def async_disconnect(self) -> None:
         async with self._mutex:
             if disconnected_future := self.sync_disconnect():
                 # Cleanup the mqtt client threads
-                await self.event_loop.run_in_executor(None, self._mqtt_client.loop_stop)
                 try:
                     await disconnected_future
                 except VacuumError as err: