From 127cc282e4efdd8df50ec0d9780de7aa9f90923e Mon Sep 17 00:00:00 2001 From: Jahongir Qurbonov Date: Thu, 24 Oct 2024 11:20:29 +0500 Subject: [PATCH] Fix issues --- client/src/telethon/_impl/mtsender/sender.py | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/client/src/telethon/_impl/mtsender/sender.py b/client/src/telethon/_impl/mtsender/sender.py index e5fba4c8..b8ef0457 100644 --- a/client/src/telethon/_impl/mtsender/sender.py +++ b/client/src/telethon/_impl/mtsender/sender.py @@ -257,8 +257,9 @@ class Sender: async def _try_read(self) -> None: self._read_done.clear() + timeout = self._next_ping - asyncio.get_running_loop().time() try: - async with asyncio.timeout(PING_DELAY): + async with asyncio.timeout(timeout): recv_data = await self._reader.read(MAXIMUM_DATA) except TimeoutError: pass @@ -269,6 +270,9 @@ class Sender: self._read_done.set() def _try_fill_write(self) -> None: + if not self._requests: + return + for request in self._requests: if isinstance(request.state, NotSerialized): if (msg_id := self._mtp.push(request.body)) is not None: