Lines Matching refs:async

28     async def test_repr(self):
37     async def test_lock(self):
48     async def test_lock_doesnt_accept_loop_parameter(self):
67     async def test_lock_by_with_statement(self):
86     async def test_acquire(self):
92         async def c1(result):
97         async def c2(result):
102         async def c3(result):
137     async def test_acquire_cancel(self):
147     async def test_cancel_race(self):
164         async def lockit(name, blocker):
194     async def test_cancel_release_race(self):
203         async def lockit():
239     async def test_finished_waiter_cancelled(self):
262     async def test_release_not_acquired(self):
267     async def test_release_no_waiters(self):
275     async def test_context_manager(self):
279         async with lock:
301     async def test_wait(self):
307         async def c1(result):
311         async def c2(result):
315         async def c3(result):
338     async def test_wait_on_set(self):
345     async def test_wait_cancel(self):
354     async def test_clear(self):
364     async def test_clear_with_waiters(self):
368         async def c1(result):
395     async def test_wait(self):
399         async def c1(result):
405         async def c2(result):
411         async def c3(result):
458     async def test_wait_cancel(self):
469     async def test_wait_cancel_contested(self):
494     async def test_wait_cancel_after_notify(self):
500         async def wait_on_cond():
502             async with cond:
520     async def test_wait_unacquired(self):
525     async def test_wait_for(self):
534         async def c1(result):
562     async def test_wait_for_unacquired(self):
572     async def test_notify(self):
576         async def c1(result):
583         async def c2(result):
590         async def c3(result):
624     async def test_notify_all(self):
629         async def c1(result):
636         async def c2(result):
668     async def test_repr(self):
684     async def test_context_manager(self):
687         async with cond:
691     async def test_explicit_lock(self):
692         async def f(lock=None, cond=None):
700             async with cond:
705             async with lock:
717     async def test_ambiguous_loops(self):
721         async def wrong_loop_in_lock():
726             async with lock:
738         async def wrong_loop_in_cond():
741             async with lock:
755     async def test_timeout_in_block(self):
757         async with condition:
768     async def test_repr(self):
789     async def test_semaphore(self):
805     async def test_acquire(self):
813         async def c1(result):
818         async def c2(result):
823         async def c3(result):
828         async def c4(result):
866     async def test_acquire_cancel(self):
877     async def test_acquire_cancel_before_awoken(self):
902     async def test_acquire_hang(self):
916     async def test_acquire_no_hang(self):
920         async def c1():
921             async with sem:
925         async def c2():
926             async with sem:
943     async def test_release_no_waiters(self):
951     async def test_acquire_fifo_order(self):
955         async def coro(tag):
966         async with asyncio.TaskGroup() as tg:
976     async def test_acquire_fifo_order_2(self):
980         async def c1(result):
985         async def c2(result):
993         async def c3(result):
1011     async def test_acquire_fifo_order_3(self):
1015         async def c1(result):
1020         async def c2(result):
1025         async def c3(result):
1050     async def asyncSetUp(self):
1058     async def gather_tasks(self, n, coro):
1063     async def test_barrier(self):
1074     async def test_repr(self):
1081         async def wait(barrier):
1125     async def test_barrier_parties(self):
1131     async def test_context_manager(self):
1136         async def coro():
1137             async with barrier as i:
1146     async def test_filling_one_task(self):
1149         async def f():
1150             async with barrier as i:
1159     async def test_filling_one_task_twice(self):
1175     async def test_filling_task_by_task(self):
1197     async def test_filling_tasks_wait_twice(self):
1201         async def coro():
1202             async with barrier:
1205                 async with barrier:
1217     async def test_filling_tasks_check_return_value(self):
1222         async def coro():
1223             async with barrier:
1226                 async with barrier as i:
1241     async def test_draining_state(self):
1245         async def coro():
1246             async with barrier:
1259     async def test_blocking_tasks_while_draining(self):
1267         async def coro():
1288     async def test_filling_tasks_cancel_one(self):
1293         async def coro():
1325     async def test_reset_barrier(self):
1334     async def test_reset_barrier_while_tasks_waiting(self):
1338         async def coro():
1344         async def coro_reset():
1361     async def test_reset_barrier_when_tasks_half_draining(self):
1366         async def coro():
1385     async def test_reset_barrier_when_tasks_half_draining_half_blocking(self):
1392         async def coro():
1425     async def test_reset_barrier_while_tasks_waiting_and_waiting_again(self):
1430         async def coro1():
1439         async def coro2():
1440             async with barrier:
1463     async def test_reset_barrier_while_tasks_draining(self):
1470         async def coro():
1508     async def test_abort_barrier(self):
1517     async def test_abort_barrier_when_tasks_half_draining_half_blocking(self):
1524         async def coro():
1551     async def test_abort_barrier_when_exception(self):
1557         async def coro():
1559                 async with barrier as i :
1562                 async with barrier:
1577     async def test_abort_barrier_when_exception_then_resetting(self):
1585         async def coro():