From 4be248932db6ce28a19fce717f1ff2cf9836b5b8 Mon Sep 17 00:00:00 2001 From: Lonami Exo Date: Wed, 27 Jun 2018 10:26:26 +0200 Subject: [PATCH] Fix non-ending awaits due to requests not being resent on reconnect --- telethon/network/mtprotosender.py | 3 +++ 1 file changed, 3 insertions(+) diff --git a/telethon/network/mtprotosender.py b/telethon/network/mtprotosender.py index 0d40e6b6..d821a023 100644 --- a/telethon/network/mtprotosender.py +++ b/telethon/network/mtprotosender.py @@ -304,6 +304,9 @@ class MTProtoSender: for retry in range(1, retries + 1): try: await self._connect() + for m in self._pending_messages.values(): + self._send_queue.put_nowait(m) + break except ConnectionError: __log__.info('Failed reconnection retry %d/%d', retry, retries)