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: