test_runners.py - OpenGrok cross reference for /third_party/python/Lib/test/test_asyncio/test

Lines Matching defs:asyncio
2 import asyncio
15     asyncio.set_event_loop_policy(None)
22 class TestPolicy(asyncio.AbstractEventLoopPolicy):
29         # shouldn't ever be called by asyncio.run()
45         loop = asyncio.BaseEventLoop()
64         asyncio.set_event_loop_policy(policy)
67         policy = asyncio.get_event_loop_policy()
72         asyncio.set_event_loop_policy(None)
80             await asyncio.sleep(0)
83         self.assertEqual(asyncio.run(main()), 42)
87             await asyncio.sleep(0)
91             asyncio.run(main())
98                 asyncio.run(o)
102             loop = asyncio.get_event_loop()
105         asyncio.run(main(False))
106         asyncio.run(main(True), debug=True)
107         with mock.patch('asyncio.coroutines._is_debug_mode', lambda: True):
108             asyncio.run(main(True))
109             asyncio.run(main(False), debug=False)
115                 asyncio.run(coro)
121             asyncio.run(main())
127             await asyncio.sleep(0.1)
131             lo_task = asyncio.create_task(leftover())
134         self.assertEqual(asyncio.run(main()), 123)
143                 await asyncio.sleep(0.1)
144             except asyncio.CancelledError:
148             loop = asyncio.get_running_loop()
152             lo_task = asyncio.create_task(leftover())
155         self.assertEqual(asyncio.run(main()), 123)
159             'message': test_utils.MockPattern(r'asyncio.run.*shutdown'),
174                 await asyncio.sleep(1)
182             except asyncio.CancelledError:
186             loop = asyncio.get_running_loop()
190             lazyboy = asyncio.create_task(spin())
194             asyncio.run(main())
205             await asyncio.sleep(0)
208         policy = asyncio.get_event_loop_policy()
210         asyncio.run(main())
217                 self._task = asyncio.Task(coro, loop=loop, **kwargs)
250             await asyncio.Event().wait()
257         asyncio.set_event_loop_policy(TestPolicy(new_event_loop))
258         with self.assertRaises(asyncio.CancelledError):
259             asyncio.run(main())
265         with asyncio.Runner(debug=False) as runner:
269         with asyncio.Runner(debug=True) as runner:
274         with asyncio.Runner(loop_factory=lambda: loop) as runner:
279             await asyncio.sleep(0)
282         with asyncio.Runner() as runner:
295         with asyncio.Runner() as runner:
303         with asyncio.Runner() as runner:
312         runner = asyncio.Runner()
324         runner = asyncio.Runner()
340         runner = asyncio.Runner()
358             await asyncio.sleep(0)
365         with asyncio.Runner() as runner:
378         with asyncio.Runner() as runner:
397             with self.assertRaises(asyncio.CancelledError):
399                     await asyncio.sleep(0)
400             raise asyncio.CancelledError()
402         with asyncio.Runner() as runner:
412             with self.assertRaises(asyncio.CancelledError):
414             raise asyncio.CancelledError()
416         with asyncio.Runner() as runner:
430             await asyncio.sleep(0)
435             asyncio.create_task(subtask(asyncio.current_task()))
436             await asyncio.sleep(10)
438         with asyncio.Runner() as runner:
439             with self.assertRaises(asyncio.CancelledError):
449         with asyncio.Runner() as runner:
464         policy = asyncio.get_event_loop_policy()
466         runner = asyncio.Runner()