From 2931eee561cdc734e88c7fc95ba4d1789f6d31a6 Mon Sep 17 00:00:00 2001 From: Jahongir Qurbonov Date: Wed, 16 Oct 2024 19:13:49 +0500 Subject: [PATCH] Remove next_ping --- client/src/telethon/_impl/mtsender/sender.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/client/src/telethon/_impl/mtsender/sender.py b/client/src/telethon/_impl/mtsender/sender.py index 20962125..fd21d376 100644 --- a/client/src/telethon/_impl/mtsender/sender.py +++ b/client/src/telethon/_impl/mtsender/sender.py @@ -188,7 +188,6 @@ class Sender: _updates: list[Updates] _requests: list[Request[object]] _request_event: Event - _next_ping: float _read_buffer: bytearray _step_lock: Lock _step_event: Event @@ -220,7 +219,6 @@ class Sender: _updates=[], _requests=[], _request_event=Event(), - _next_ping=asyncio.get_running_loop().time() + PING_DELAY, _read_buffer=bytearray(), _step_lock=Lock(), _step_event=Event(), @@ -293,9 +291,7 @@ class Sender: try: while True: _, pending = await asyncio.wait( - (recv_data, send_data), - timeout=self._next_ping - asyncio.get_running_loop().time(), - return_when=FIRST_COMPLETED, + (recv_data, send_data), return_when=FIRST_COMPLETED ) # pyright: ignore [reportAssignmentType] yield @@ -381,7 +377,6 @@ class Sender: ) ) ) - self._next_ping = asyncio.get_running_loop().time() + PING_DELAY def _process_mtp_buffer(self, updates: list[Updates]) -> None: results = self._mtp.deserialize(self._mtp_buffer) @@ -558,5 +553,4 @@ async def generate_auth_key(sender: Sender) -> Sender: first_salt = finished.first_salt sender._mtp = Encrypted(auth_key, time_offset=time_offset, first_salt=first_salt) - sender._next_ping = asyncio.get_running_loop().time() + PING_DELAY return sender