From accaf2f9bbf56a583bd99fb29599c508f1dd95c3 Mon Sep 17 00:00:00 2001 From: Jahongir Qurbonov Date: Mon, 21 Oct 2024 21:06:53 +0500 Subject: [PATCH] Refactor sender --- client/src/telethon/_impl/client/client/net.py | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/client/src/telethon/_impl/client/client/net.py b/client/src/telethon/_impl/client/client/net.py index 5f4b4a7a..808c4b6b 100644 --- a/client/src/telethon/_impl/client/client/net.py +++ b/client/src/telethon/_impl/client/client/net.py @@ -246,9 +246,10 @@ async def invoke_request( sleep_thresh = client._config.flood_sleep_threshold rx = client._sender.enqueue(request) while True: - await step_sender(client) + while not rx.done(): + await step_sender(client) try: - response = await rx + response = rx.result() break except RpcError as e: if e.code == 420 and e.value is not None and e.value < sleep_thresh: