From 91e997ed15731ec1d3ad5b8da0345492c4969797 Mon Sep 17 00:00:00 2001 From: Lonami Exo Date: Fri, 25 Oct 2024 23:20:22 +0200 Subject: [PATCH] Wait on step_done only for reads Otherwise it gets into an infinite loop. --- client/src/telethon/_impl/mtsender/sender.py | 9 +-------- 1 file changed, 1 insertion(+), 8 deletions(-) diff --git a/client/src/telethon/_impl/mtsender/sender.py b/client/src/telethon/_impl/mtsender/sender.py index c5da137c..1a46f6b9 100644 --- a/client/src/telethon/_impl/mtsender/sender.py +++ b/client/src/telethon/_impl/mtsender/sender.py @@ -246,8 +246,7 @@ class Sender: self._reading = True await self._do_read() self._reading = False - - if not self._step_done.is_set(): + else: await self._step_done.wait() def pop_updates(self) -> list[Updates]: @@ -271,12 +270,6 @@ class Sender: self._step_done.set() async def _do_write(self) -> None: - self._step_done.clear() - await self._try_fill_write() - self._try_timeout_ping() - self._step_done.set() - - async def _try_fill_write(self) -> None: if not self._requests: return