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

Remove drain

Browse Source
This commit is contained in:
Jahongir Qurbonov 2024-10-23 10:47:08 +05:00
parent f3c7ba32d3
commit 3b456c63b6
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
client/src/telethon/_impl/mtsender/sender.py
View File

@ -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")