atse/thermostat
1
0
Fork 0
forked from M-Labs/thermostat
Code Issues Pull Requests Activity

Should not stop cancelling read if timeout'd

Browse Source
This commit is contained in:
atse 2024-07-04 17:30:49 +08:00
parent 7019bbe004
commit 1ab5c9e7ee
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
pytec/pytec/aioclient.py
View File

@ -93,8 +93,7 @@ class Client:
async def _command(self, *command): async def _command(self, *command):
async with self._command_lock: async with self._command_lock:
# protect the read-write process from being cancelled midway line = await self._read_write(command)
line = await asyncio.shield(self._read_write(command))
response = json.loads(line) response = json.loads(line)
logging.debug(f"{command}: {response}") logging.debug(f"{command}: {response}")