Message281536
adding to asyncio.Queue class following methods:
def __aiter__(self): return self
async def __anext__(self): return await self.get()
let use asyncio.Queue follow:
queue = asyncio.Queue()
...
async for item in queue: do_something_with(item) |
|
Date |
User |
Action |
Args |
2016-11-23 04:58:52 | RekGRpth | set | recipients:
+ RekGRpth, gvanrossum, yselivanov |
2016-11-23 04:58:52 | RekGRpth | set | messageid: <1479877132.48.0.693527153069.issue28777@psf.upfronthosting.co.za> |
2016-11-23 04:58:52 | RekGRpth | link | issue28777 messages |
2016-11-23 04:58:51 | RekGRpth | create | |
|