mirror of
https://github.com/natekspencer/hacs-oasis_mini.git
synced 2025-11-13 23:53:51 -05:00
Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
3acd45da9d | ||
|
|
a736c72c8e | ||
|
|
c87bb241ef |
@@ -6,7 +6,6 @@ from typing import Any, Awaitable, Callable, Final
|
|||||||
from urllib.parse import urljoin
|
from urllib.parse import urljoin
|
||||||
|
|
||||||
from aiohttp import ClientResponseError, ClientSession
|
from aiohttp import ClientResponseError, ClientSession
|
||||||
import async_timeout
|
|
||||||
|
|
||||||
from .utils import _bit_to_bool
|
from .utils import _bit_to_bool
|
||||||
|
|
||||||
@@ -400,11 +399,8 @@ class OasisMini:
|
|||||||
|
|
||||||
async def _async_command(self, **kwargs: Any) -> str | None:
|
async def _async_command(self, **kwargs: Any) -> str | None:
|
||||||
"""Send a command to the device."""
|
"""Send a command to the device."""
|
||||||
with async_timeout.timeout(5):
|
result = await self._async_get(**kwargs)
|
||||||
while self.busy:
|
_LOGGER.debug("Result: %s", result)
|
||||||
await asyncio.sleep(0.1)
|
|
||||||
result = await self._async_get(**kwargs)
|
|
||||||
_LOGGER.debug("Result: %s", result)
|
|
||||||
|
|
||||||
async def _async_get(self, **kwargs: Any) -> str | None:
|
async def _async_get(self, **kwargs: Any) -> str | None:
|
||||||
"""Perform a GET request."""
|
"""Perform a GET request."""
|
||||||
|
|||||||
Reference in New Issue
Block a user