small fix

2025-12-12 01:24:29 +05:00 · 2021-01-23 21:08:33 +03:00
1 changed files with 2 additions and 1 deletions
--- a/custom_components/mega/hub.py
+++ b/custom_components/mega/hub.py
@@ -177,7 +177,8 @@ class MegaD:
                qos=2,
                retain=False,
            )
-            await asyncio.wait_for(self.cnd.wait_for(lambda: self.last_port == port), timeout=15)
+            await asyncio.wait_for(self.cnd.wait(), timeout=15)
+            await asyncio.sleep(0.05)

    async def get_all_ports(self):
        for x in range(37):