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

Fix not all items being put back in sync (#886)

Browse Source
This commit is contained in:
Lonami Exo 2018-07-10 09:51:27 +02:00
parent 1f7e8ad279
commit 2efd78000f
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
telethon/network/mtprotosender.py
View File

@ -775,11 +775,16 @@ class _ContainerQueue(queue.Queue):
items = self.get_nowait() items = self.get_nowait()
if not isinstance(items, list): if not isinstance(items, list):
items = [items] items = [items]
items = iter(items)
for item in items: for item in items:
if (item == _reconnect_sentinel or if (item == _reconnect_sentinel or
isinstance(item.obj, MessageContainer) isinstance(item.obj, MessageContainer)
or size + item.size() > MessageContainer.MAXIMUM_SIZE): or size + item.size() > MessageContainer.MAXIMUM_SIZE):
self.put_nowait(item) self.put_nowait(item)
for item in items:
self.put_nowait(item)
return result # break 2 levels return result # break 2 levels
else: else:
size += item.size() size += item.size()