Lines Matching refs:wait

308             if await ev.wait():
312             if await ev.wait():
316             if await ev.wait():
342         res = await ev.wait()
348         wait = asyncio.create_task(ev.wait())
349         asyncio.get_running_loop().call_soon(wait.cancel)
351             await wait
369             if await ev.wait():
401             if await cond.wait():
407             if await cond.wait():
413             if await cond.wait():
462         wait = asyncio.create_task(cond.wait())
463         asyncio.get_running_loop().call_soon(wait.cancel)
465             await wait
475         wait_task = asyncio.create_task(cond.wait())
504                 await cond.wait()
523             await cond.wait()
578             if await cond.wait():
585             if await cond.wait():
592             if await cond.wait():
631             if await cond.wait():
638             if await cond.wait():
750                     await cond.wait()
759                 await asyncio.wait_for(condition.wait(), timeout=0.5)
1081         async def wait(barrier):
1082             await barrier.wait()
1086             waiters.append(asyncio.create_task(wait(barrier)))
1095             waiters.append(asyncio.create_task(wait(barrier)))
1103             waiters.append(asyncio.create_task(wait(barrier)))
1113             waiters.append(asyncio.create_task(wait(barrier)))
1162         t1 = asyncio.create_task(barrier.wait())
1166         t2 = asyncio.create_task(barrier.wait())
1179         t1 = asyncio.create_task(barrier.wait())
1184         t2 = asyncio.create_task(barrier.wait())
1189         t3 = asyncio.create_task(barrier.wait())
1192         await asyncio.wait([t1, t2, t3])
1271             await barrier.wait()
1276                 # wait again only for rewait tasks
1277                 await barrier.wait()
1279                 # wait for end of draining state`
1280                 await barrier_nowaiting.wait()
1281                 # wait for other waiting tasks
1282                 await barrier.wait()
1294             await barrier.wait()
1340                 await barrier.wait()
1368                 await barrier.wait()
1395                 await barrier.wait()
1401                 await barrier.wait()
1409                     await barrier.wait()
1412                         await barrier.wait()
1414                         # here no catch - blocked tasks go to wait
1432                 await barrier.wait()
1436                 await barrier.wait()
1473             i = await barrier.wait()
1480                 await barrier.wait()
1484                     await barrier.wait()
1493             # last wait, must be completed
1494             k = await barrier.wait()
1527                 await barrier.wait()
1538                         await barrier.wait()
1587                 i = await barrier1.wait()
1590                 await barrier1.wait()
1600             i = await barrier2.wait()
1603             await barrier2.wait()
1604             await barrier1.wait()