forked from M-Labs/thermostat
Remove all timeouts from aioclient
This commit is contained in:
parent
50c1bb5929
commit
cebf995427
@ -13,7 +13,6 @@ class AsyncioClient:
|
|||||||
self._writer = None
|
self._writer = None
|
||||||
self._command_lock = asyncio.Lock()
|
self._command_lock = asyncio.Lock()
|
||||||
self._report_mode_on = False
|
self._report_mode_on = False
|
||||||
self.timeout = None
|
|
||||||
|
|
||||||
async def start_session(self, host="192.168.1.26", port=23):
|
async def start_session(self, host="192.168.1.26", port=23):
|
||||||
"""Start session to Thermostat at specified host and port.
|
"""Start session to Thermostat at specified host and port.
|
||||||
@ -54,9 +53,7 @@ class AsyncioClient:
|
|||||||
|
|
||||||
async def _read_line(self):
|
async def _read_line(self):
|
||||||
# read 1 line
|
# read 1 line
|
||||||
chunk = await asyncio.wait_for(
|
chunk = await self._reader.readline()
|
||||||
self._reader.readline(), self.timeout
|
|
||||||
) # Only wait for response until timeout
|
|
||||||
return chunk.decode("utf-8", errors="ignore")
|
return chunk.decode("utf-8", errors="ignore")
|
||||||
|
|
||||||
async def _read_write(self, command):
|
async def _read_write(self, command):
|
||||||
|
Loading…
Reference in New Issue
Block a user