mirror of
https://github.com/LonamiWebs/Telethon.git
synced 2025-08-08 04:52:30 +00:00
Fix logging bug on disconnect
This commit is contained in:
@@ -258,7 +258,6 @@ class MTProtoSender:
|
|||||||
self._log.debug('Closing current connection...')
|
self._log.debug('Closing current connection...')
|
||||||
await self._connection.disconnect()
|
await self._connection.disconnect()
|
||||||
finally:
|
finally:
|
||||||
self._connection = None
|
|
||||||
self._log.debug('Cancelling %d pending message(s)...', len(self._pending_state))
|
self._log.debug('Cancelling %d pending message(s)...', len(self._pending_state))
|
||||||
for state in self._pending_state.values():
|
for state in self._pending_state.values():
|
||||||
if error and not state.future.done():
|
if error and not state.future.done():
|
||||||
@@ -273,7 +272,9 @@ class MTProtoSender:
|
|||||||
recv_loop_handle=self._recv_loop_handle
|
recv_loop_handle=self._recv_loop_handle
|
||||||
)
|
)
|
||||||
|
|
||||||
self._log.info('Disconnection from %s complete!', self._connection)
|
self._log.info('Disconnection from %s complete!', self._connection)
|
||||||
|
self._connection = None
|
||||||
|
|
||||||
if self._disconnected and not self._disconnected.done():
|
if self._disconnected and not self._disconnected.done():
|
||||||
if error:
|
if error:
|
||||||
self._disconnected.set_exception(error)
|
self._disconnected.set_exception(error)
|
||||||
|
Reference in New Issue
Block a user