Lines Matching defs:asyncio
29 import asyncio
30 from asyncio import coroutines
31 from asyncio import events
32 from asyncio import proactor_events
33 from asyncio import selector_events
42 asyncio.set_event_loop_policy(None)
60 loop = asyncio.new_event_loop()
61 asyncio.set_event_loop(loop)
79 class MyBaseProto(asyncio.Protocol):
123 class MyDatagramProto(asyncio.DatagramProtocol):
155 class MyReadPipeProto(asyncio.Protocol):
191 class MyWritePipeProto(asyncio.BaseProtocol):
216 class MySubprocessProtocol(asyncio.SubprocessProtocol):
226 self.got_data = {1: asyncio.Event(),
227 2: asyncio.Event()}
279 await asyncio.sleep(0)
297 self.loop.run_until_complete(asyncio.sleep(0.1))
305 await asyncio.sleep(0.1)
529 self.assertIsInstance(tr, asyncio.Transport)
530 self.assertIsInstance(pr, asyncio.Protocol)
591 self.assertIsInstance(tr, asyncio.Transport)
592 self.assertIsInstance(pr, asyncio.Protocol)
796 @mock.patch('asyncio.base_events.socket')
1285 self.assertIsInstance(s_transport, asyncio.Transport)
1295 self.assertIsInstance(transport, asyncio.Transport)
1345 self.assertIsInstance(tr, asyncio.Transport)
1661 except asyncio.CancelledError:
1676 self.assertRaises(asyncio.CancelledError, f.result)
1695 await asyncio.sleep(1e-2)
1696 await asyncio.sleep(1e-4)
1697 await asyncio.sleep(1e-6)
1698 await asyncio.sleep(1e-8)
1699 await asyncio.sleep(1e-10)
2036 asyncio.SubprocessProtocol,
2052 asyncio.SubprocessProtocol,
2071 return asyncio.SelectorEventLoop()
2078 return asyncio.ProactorEventLoop()
2100 watcher = asyncio.SafeChildWatcher()
2102 asyncio.set_child_watcher(watcher)
2105 asyncio.set_child_watcher(None)
2115 return asyncio.SelectorEventLoop(
2140 return asyncio.SelectorEventLoop(selectors.EpollSelector())
2148 return asyncio.SelectorEventLoop(selectors.PollSelector())
2156 return asyncio.SelectorEventLoop(selectors.SelectSelector())
2175 h = asyncio.Handle(callback, args, self.loop)
2190 h = asyncio.Handle(callback, (), self.loop)
2202 h = asyncio.Handle(lambda: None, (), self.loop)
2209 h = asyncio.Handle(noop, (1, 2), self.loop)
2222 h = asyncio.Handle(cb, (), self.loop)
2229 h = asyncio.Handle(cb, (3,), self.loop)
2236 h = asyncio.Handle(cb, (2, 3), self.loop)
2245 h = asyncio.Handle(cb, (), self.loop)
2258 h = asyncio.Handle(noop, (1, 2), self.loop)
2279 loop = asyncio.get_event_loop_policy().new_event_loop()
2310 # Test that asyncio can format coroutines that are instances of
2316 self.assertTrue(asyncio.iscoroutine(coro))
2349 h = asyncio.TimerHandle(when, lambda: False, (),
2355 h = asyncio.TimerHandle(when, lambda: False, (),
2365 h = asyncio.TimerHandle(when, callback, args, mock.Mock())
2381 h = asyncio.TimerHandle(123, noop, (), self.loop)
2397 h = asyncio.TimerHandle(123, noop, (), self.loop)
2418 h1 = asyncio.TimerHandle(when, callback, (), self.loop)
2419 h2 = asyncio.TimerHandle(when, callback, (), self.loop)
2435 h1 = asyncio.TimerHandle(when, callback, (), self.loop)
2436 h2 = asyncio.TimerHandle(when + 10.0, callback, (), self.loop)
2448 h3 = asyncio.Handle(callback, (), self.loop)
2479 loop = asyncio.AbstractEventLoop()
2535 loop = asyncio.AbstractEventLoop()
2572 loop = asyncio.new_event_loop()
2580 policy = asyncio.AbstractEventLoopPolicy()
2589 policy = asyncio.DefaultEventLoopPolicy()
2592 self.assertIsInstance(loop, asyncio.AbstractEventLoop)
2599 policy = asyncio.DefaultEventLoopPolicy()
2616 policy = asyncio.DefaultEventLoopPolicy()
2620 @mock.patch('asyncio.events.threading.current_thread')
2624 policy = asyncio.DefaultEventLoopPolicy()
2632 policy = asyncio.DefaultEventLoopPolicy()
2635 self.assertIsInstance(loop, asyncio.AbstractEventLoop)
2639 policy = asyncio.DefaultEventLoopPolicy()
2653 policy = asyncio.get_event_loop_policy()
2654 self.assertIsInstance(policy, asyncio.AbstractEventLoopPolicy)
2655 self.assertIs(policy, asyncio.get_event_loop_policy())
2659 TypeError, asyncio.set_event_loop_policy, object())
2661 old_policy = asyncio.get_event_loop_policy()
2663 policy = asyncio.DefaultEventLoopPolicy()
2664 asyncio.set_event_loop_policy(policy)
2665 self.assertIs(policy, asyncio.get_event_loop_policy())
2687 asyncio._get_running_loop = type(self)._get_running_loop_impl
2688 asyncio._set_running_loop = type(self)._set_running_loop_impl
2689 asyncio.get_running_loop = type(self).get_running_loop_impl
2690 asyncio.get_event_loop = type(self).get_event_loop_impl
2694 self.loop = asyncio.new_event_loop()
2695 asyncio.set_event_loop(self.loop)
2698 watcher = asyncio.SafeChildWatcher()
2700 asyncio.set_child_watcher(watcher)
2705 asyncio.set_child_watcher(None)
2710 asyncio.set_event_loop(None)
2717 asyncio._get_running_loop = self._get_running_loop_saved
2718 asyncio._set_running_loop = self._set_running_loop_saved
2719 asyncio.get_running_loop = self.get_running_loop_saved
2720 asyncio.get_event_loop = self.get_event_loop_saved
2745 class Policy(asyncio.DefaultEventLoopPolicy):
2749 old_policy = asyncio.get_event_loop_policy()
2751 asyncio.set_event_loop_policy(Policy())
2752 loop = asyncio.new_event_loop()
2755 asyncio.get_event_loop()
2756 asyncio.set_event_loop(None)
2758 asyncio.get_event_loop()
2761 asyncio.get_running_loop()
2762 self.assertIs(asyncio._get_running_loop(), None)
2765 self.assertIs(asyncio.get_event_loop(), loop)
2766 self.assertIs(asyncio.get_running_loop(), loop)
2767 self.assertIs(asyncio._get_running_loop(), loop)
2771 asyncio.set_event_loop(loop)
2773 asyncio.get_event_loop()
2774 asyncio.set_event_loop(None)
2776 asyncio.get_event_loop()
2779 asyncio.set_event_loop_policy(old_policy)
2784 asyncio.get_running_loop()
2786 self.assertIs(asyncio._get_running_loop(), None)
2789 old_policy = asyncio.get_event_loop_policy()
2791 asyncio.set_event_loop_policy(asyncio.DefaultEventLoopPolicy())
2792 loop = asyncio.new_event_loop()
2795 loop2 = asyncio.get_event_loop()
2797 asyncio.set_event_loop(None)
2799 asyncio.get_event_loop()
2802 asyncio.get_running_loop()
2803 self.assertIs(asyncio._get_running_loop(), None)
2806 self.assertIs(asyncio.get_event_loop(), loop)
2807 self.assertIs(asyncio.get_running_loop(), loop)
2808 self.assertIs(asyncio._get_running_loop(), loop)
2812 asyncio.set_event_loop(loop)
2813 self.assertIs(asyncio.get_event_loop(), loop)
2815 asyncio.set_event_loop(None)
2817 asyncio.get_event_loop()
2820 asyncio.set_event_loop_policy(old_policy)
2825 asyncio.get_running_loop()
2827 self.assertIs(asyncio._get_running_loop(), None)
2855 loop = asyncio.new_event_loop()
2871 loop = asyncio.new_event_loop()