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

Rename event

Browse Source
This commit is contained in:
Jahongir Qurbonov 2024-10-23 12:55:38 +05:00
parent 3c5be9f460
commit c9c7bc6c6d
1 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -167,12 +167,12 @@ class Sender:
_writer: AsyncWriter _writer: AsyncWriter
_reading: bool _reading: bool
_writing: bool _writing: bool
_read_done: Event
_transport: Transport _transport: Transport
_mtp: Mtp _mtp: Mtp
_mtp_buffer: bytearray _mtp_buffer: bytearray
_updates: list[Updates] _updates: list[Updates]
_requests: list[Request[object]] _requests: list[Request[object]]
_response_event: Event
_next_ping: float _next_ping: float
_read_buffer: bytearray _read_buffer: bytearray
@ -194,16 +194,16 @@ class Sender:
dc_id=dc_id, dc_id=dc_id,
addr=addr, addr=addr,
_logger=base_logger.getChild("mtsender"), _logger=base_logger.getChild("mtsender"),
_reading=False,
_writing=False,
_reader=reader, _reader=reader,
_writer=writer, _writer=writer,
_reading=False,
_writing=False,
_read_done=Event(),
_transport=transport, _transport=transport,
_mtp=mtp, _mtp=mtp,
_mtp_buffer=bytearray(), _mtp_buffer=bytearray(),
_updates=[], _updates=[],
_requests=[], _requests=[],
_response_event=Event(),
_next_ping=asyncio.get_running_loop().time() + PING_DELAY, _next_ping=asyncio.get_running_loop().time() + PING_DELAY,
_read_buffer=bytearray(), _read_buffer=bytearray(),
) )
@ -211,7 +211,7 @@ class Sender:
async def disconnect(self) -> None: async def disconnect(self) -> None:
self._writer.close() self._writer.close()
await self._writer.wait_closed() await self._writer.wait_closed()
self._response_event.set() self._read_done.set()
def enqueue(self, request: RemoteCall[Return]) -> Future[bytes]: def enqueue(self, request: RemoteCall[Return]) -> Future[bytes]:
rx = self._enqueue_body(bytes(request)) rx = self._enqueue_body(bytes(request))
@ -247,7 +247,7 @@ class Sender:
await self._try_read() await self._try_read()
self._reading = False self._reading = False
else: else:
await self._response_event.wait() await self._read_done.wait()
def pop_updates(self) -> list[Updates]: def pop_updates(self) -> list[Updates]:
updates = self._updates[:] updates = self._updates[:]
@ -255,7 +255,7 @@ class Sender:
return updates return updates
async def _try_read(self) -> None: async def _try_read(self) -> None:
self._response_event.clear() self._read_done.clear()
try: try:
async with asyncio.timeout(PING_DELAY): async with asyncio.timeout(PING_DELAY):
@ -266,7 +266,7 @@ class Sender:
self._on_net_read(recv_data) self._on_net_read(recv_data)
finally: finally:
self._try_timeout_ping() self._try_timeout_ping()
self._response_event.set() self._read_done.set()
def _try_fill_write(self) -> None: def _try_fill_write(self) -> None:
for request in self._requests: for request in self._requests: