Method func

test/asynchronous/test_locks.py:311–317

()

            cond = _async_create_condition(_async_create_lock())

            async def func():
                nonlocal raised
                async with cond:
                    with self.assertRaises(asyncio.CancelledError) as err:
                        await cond.wait_for(lambda: wake)
                    raised = err.exception
                    raise raised

            task = asyncio.create_task(func())
            await asyncio.sleep(0)