mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-07-11 08:32:22 +03:00
Move response_event.set to step
This commit is contained in:
parent
3b456c63b6
commit
e5adfe203e
|
@ -244,6 +244,7 @@ class Sender:
|
||||||
self._reading = True
|
self._reading = True
|
||||||
self._response_event.clear()
|
self._response_event.clear()
|
||||||
await self._try_read()
|
await self._try_read()
|
||||||
|
self._response_event.set()
|
||||||
self._reading = False
|
self._reading = False
|
||||||
else:
|
else:
|
||||||
await self._response_event.wait()
|
await self._response_event.wait()
|
||||||
|
@ -294,7 +295,6 @@ class Sender:
|
||||||
else:
|
else:
|
||||||
del self._read_buffer[:n]
|
del self._read_buffer[:n]
|
||||||
self._process_mtp_buffer()
|
self._process_mtp_buffer()
|
||||||
self._response_event.set()
|
|
||||||
|
|
||||||
def _on_ping_timeout(self) -> None:
|
def _on_ping_timeout(self) -> None:
|
||||||
ping_id = generate_random_id()
|
ping_id = generate_random_id()
|
||||||
|
|
Loading…
Reference in New Issue
Block a user