Представьте, что у нас есть оригинальный API, который возвращает генератор (на самом деле это механизм, который приносит страницы/фрагменты результатов с сервера, одновременно предоставляя пользователю простой генератор и позволяющий ему перебирать эти результаты один за другим. Для простоты:
Код: Выделить всё
# Original sync generator
def get_results():
# fetch from server
yield 1
yield 2
# fetch next page
yield 3
yield 4
# ....
Теперь необходимо реализовать асинхронную версию API, однако нам также необходимо сохранить работоспособность старого API. Здесь все усложняется: мы как бы хотим перевести асинхронный генератор в синхронный, но я не могу найти элегантного способа сделать это. Лучшее, что я мог сделать на данный момент, - это «сначала получить все результаты в список, а затем добавить в этот список фальшивый генератор синхронизации». Что противоречит цели:
Код: Выделить всё
# Async generator
async def get_results_async():
# await fetch from server
yield 1
yield 2
# await fetch next page
yield 3
yield 4
# ....
# Backward compatible sync generator
def get_results():
async def gather_all_results():
res = []
async for i in get_results_async():
res.append(i)
return res
res = asyncio.run(gather_all_results())
for i in res:
yield i
Есть ли лучший и более элегантный способ сделать это без получения всех результатов перед их возвратом?
Спасибо
Подробнее здесь:
https://stackoverflow.com/questions/715 ... o-sync-one
Мобильная версия