mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-07-11 08:32:22 +03:00
Move response_event set
This commit is contained in:
parent
276738dfc6
commit
0bd1cbb53f
|
@ -247,6 +247,7 @@ class Sender:
|
||||||
self._response_event.clear()
|
self._response_event.clear()
|
||||||
await self._try_read()
|
await self._try_read()
|
||||||
self._try_timeout_ping()
|
self._try_timeout_ping()
|
||||||
|
self._response_event.set()
|
||||||
self._reading = False
|
self._reading = False
|
||||||
else:
|
else:
|
||||||
await self._response_event.wait()
|
await self._response_event.wait()
|
||||||
|
@ -282,8 +283,6 @@ class Sender:
|
||||||
if isinstance(request.state, Serialized):
|
if isinstance(request.state, Serialized):
|
||||||
request.state = Sent(request.state.msg_id, container_msg_id)
|
request.state = Sent(request.state.msg_id, container_msg_id)
|
||||||
|
|
||||||
self._response_event.set()
|
|
||||||
|
|
||||||
def _try_timeout_ping(self) -> None:
|
def _try_timeout_ping(self) -> None:
|
||||||
current_time = asyncio.get_running_loop().time()
|
current_time = asyncio.get_running_loop().time()
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue
Block a user