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

Fix yield_ must be awaited

Browse Source
This commit is contained in:
Lonami Exo 2018-05-10 10:11:30 +02:00
parent 6130b8918d
commit ed8c123b9a
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
telethon/telegram_client.py
View File

@ -611,7 +611,7 @@ class TelegramClient(TelegramBareClient):
peer_id = utils.get_peer_id(d.peer)
if peer_id not in seen:
seen.add(peer_id)
yield_(Dialog(self, d, entities, messages))
await yield_(Dialog(self, d, entities, messages))
if len(r.dialogs) < req.limit or not isinstance(r, DialogsSlice):
# Less than we requested means we reached the end, or
@ -647,7 +647,7 @@ class TelegramClient(TelegramBareClient):
among other things.
"""
for update in (await self(GetAllDraftsRequest())).updates:
yield_(Draft._from_update(self, update))
await yield_(Draft._from_update(self, update))
async def get_drafts(self):
"""
@ -1176,7 +1176,7 @@ class TelegramClient(TelegramBareClient):
PeerChannel(message.fwd_from.channel_id)
)]
)
yield_(message)
await yield_(message)
have += 1
if len(r.messages) < request.limit:
@ -1399,7 +1399,7 @@ class TelegramClient(TelegramBareClient):
seen.add(participant.user_id)
user = users[participant.user_id]
user.participant = participant
yield_(user)
await yield_(user)
if len(seen) >= limit:
return
@ -1426,7 +1426,7 @@ class TelegramClient(TelegramBareClient):
else:
user = users[participant.user_id]
user.participant = participant
yield_(user)
await yield_(user)
else:
if _total:
_total[0] = 1
@ -1434,7 +1434,7 @@ class TelegramClient(TelegramBareClient):
user = await self.get_entity(entity)
if filter_entity(user):
user.participant = None
yield_(user)
await yield_(user)
async def get_participants(self, *args, **kwargs):
"""