LonamiWebs/Telethon
1
1
Fork 0
mirror of https://github.com/LonamiWebs/Telethon.git synced 2025-07-13 01:22:21 +03:00
Code Issues Packages Projects Releases Wiki Activity

Refactor step

Browse Source
This commit is contained in:
Jahongir Qurbonov 2024-10-23 12:49:49 +05:00
parent 0bd1cbb53f
commit 3c5be9f460
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -244,10 +244,7 @@ class Sender:
if not self._reading: if not self._reading:
self._reading = True self._reading = True
self._response_event.clear()
await self._try_read() await self._try_read()
self._try_timeout_ping()
self._response_event.set()
self._reading = False self._reading = False
else: else:
await self._response_event.wait() await self._response_event.wait()
@ -258,6 +255,8 @@ class Sender:
return updates return updates
async def _try_read(self) -> None: async def _try_read(self) -> None:
self._response_event.clear()
try: try:
async with asyncio.timeout(PING_DELAY): async with asyncio.timeout(PING_DELAY):
recv_data = await self._reader.read(MAXIMUM_DATA) recv_data = await self._reader.read(MAXIMUM_DATA)
@ -265,6 +264,9 @@ class Sender:
pass pass
else: else:
self._on_net_read(recv_data) self._on_net_read(recv_data)
finally:
self._try_timeout_ping()
self._response_event.set()
def _try_fill_write(self) -> None: def _try_fill_write(self) -> None:
for request in self._requests: for request in self._requests: