Merge pull request #60 from noahhusby/refact/subscribe-model

Add timeout to async open connection
noahhusby · Sep 25, 2024 · da8bd7a · da8bd7a
2 parents d83c85a + 6880d5f
commit da8bd7a
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/aiorussound/rio.py b/aiorussound/rio.py
@@ -154,7 +154,8 @@ async def _connect_handler(self, res):
         handler_tasks = set()
         try:
             self._do_state_update = False
-            await self.connection_handler.connect()
+            async with asyncio.timeout(TIMEOUT):
+                await self.connection_handler.connect()
             handler_tasks.add(
                 asyncio.create_task(self.consumer_handler(self.connection_handler))
             )

diff --git a/pyproject.toml b/pyproject.toml
@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "aiorussound"
-version = "4.0.4"
+version = "4.0.5"
 description = "Asyncio client for Russound RIO devices."
 authors = ["Noah Husby <[email protected]>"]
 maintainers = ["Noah Husby <[email protected]>"]