From 3b456c63b63c1c94e21981592467b3f435270917 Mon Sep 17 00:00:00 2001 From: Jahongir Qurbonov Date: Wed, 23 Oct 2024 10:47:08 +0500 Subject: [PATCH] Remove drain --- client/src/telethon/_impl/mtsender/sender.py | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/client/src/telethon/_impl/mtsender/sender.py b/client/src/telethon/_impl/mtsender/sender.py index 4f6bde47..4daf5a6e 100644 --- a/client/src/telethon/_impl/mtsender/sender.py +++ b/client/src/telethon/_impl/mtsender/sender.py @@ -237,7 +237,7 @@ class Sender: async def step(self) -> None: if not self._writing: self._writing = True - await self._try_fill_write() + self._try_fill_write() self._writing = False if not self._reading: @@ -262,7 +262,7 @@ class Sender: else: self._on_net_read(recv_data) - async def _try_fill_write(self) -> None: + def _try_fill_write(self) -> None: for request in self._requests: if isinstance(request.state, NotSerialized): if (msg_id := self._mtp.push(request.body)) is not None: @@ -279,8 +279,6 @@ class Sender: if isinstance(request.state, Serialized): request.state = Sent(request.state.msg_id, container_msg_id) - await self._writer.drain() - def _on_net_read(self, read_buffer: bytes) -> None: if not read_buffer: raise ConnectionResetError("read 0 bytes")