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

Refactor sender

Browse Source
This commit is contained in:
Jahongir Qurbonov 2024-10-21 21:06:53 +05:00
parent fb8dbf6fc9
commit accaf2f9bb
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
client/src/telethon/_impl/client/client/net.py
View File

@ -246,9 +246,10 @@ async def invoke_request(
sleep_thresh = client._config.flood_sleep_threshold sleep_thresh = client._config.flood_sleep_threshold
rx = client._sender.enqueue(request) rx = client._sender.enqueue(request)
while True: while True:
while not rx.done():
await step_sender(client) await step_sender(client)
try: try:
response = await rx response = rx.result()
break break
except RpcError as e: except RpcError as e:
if e.code == 420 and e.value is not None and e.value < sleep_thresh: if e.code == 420 and e.value is not None and e.value < sleep_thresh: