LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-04-20 00:51:59 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix issues

Browse Source
This commit is contained in:
Jahongir Qurbonov 2024-10-24 11:20:29 +05:00
parent c9c7bc6c6d
commit 127cc282e4
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
client/src/telethon/_impl/mtsender/sender.py
View File

@ -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: