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

Remove next_ping

Browse Source
This commit is contained in:
Jahongir Qurbonov 2024-10-16 19:13:49 +05:00
parent 92c115733d
commit 2931eee561
1 changed files with 1 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -188,7 +188,6 @@ class Sender:
_updates: list[Updates] _updates: list[Updates]
_requests: list[Request[object]] _requests: list[Request[object]]
_request_event: Event _request_event: Event
_next_ping: float
_read_buffer: bytearray _read_buffer: bytearray
_step_lock: Lock _step_lock: Lock
_step_event: Event _step_event: Event
@ -220,7 +219,6 @@ class Sender:
_updates=[], _updates=[],
_requests=[], _requests=[],
_request_event=Event(), _request_event=Event(),
_next_ping=asyncio.get_running_loop().time() + PING_DELAY,
_read_buffer=bytearray(), _read_buffer=bytearray(),
_step_lock=Lock(), _step_lock=Lock(),
_step_event=Event(), _step_event=Event(),
@ -293,9 +291,7 @@ class Sender:
try: try:
while True: while True:
_, pending = await asyncio.wait( _, pending = await asyncio.wait(
(recv_data, send_data), (recv_data, send_data), return_when=FIRST_COMPLETED
timeout=self._next_ping - asyncio.get_running_loop().time(),
return_when=FIRST_COMPLETED,
) # pyright: ignore [reportAssignmentType] ) # pyright: ignore [reportAssignmentType]
yield 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: def _process_mtp_buffer(self, updates: list[Updates]) -> None:
results = self._mtp.deserialize(self._mtp_buffer) results = self._mtp.deserialize(self._mtp_buffer)
@ -558,5 +553,4 @@ async def generate_auth_key(sender: Sender) -> Sender:
first_salt = finished.first_salt first_salt = finished.first_salt
sender._mtp = Encrypted(auth_key, time_offset=time_offset, first_salt=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 return sender