/external/python/cpython3/Lib/test/test_asyncio/ |
test_runners.py | 1 import asyncio 8 class TestPolicy(asyncio.AbstractEventLoopPolicy): 15 # shouldn't ever be called by asyncio.run() 31 loop = asyncio.BaseEventLoop() 47 asyncio.set_event_loop_policy(policy) 50 policy = asyncio.get_event_loop_policy() 55 asyncio.set_event_loop_policy(None) 63 await asyncio.sleep(0) 66 self.assertEqual(asyncio.run(main()), 42) 70 await asyncio.sleep(0 [all...] |
test_windows_events.py | 13 import asyncio 14 from asyncio import windows_events 18 class UpperProto(asyncio.Protocol): 36 self.loop = asyncio.ProactorEventLoop() 41 trans = self.loop._make_socket_transport(a, asyncio.Protocol()) 42 f = asyncio.ensure_future(self.loop.sock_recv(b, 100), loop=self.loop) 64 asyncio.Protocol, ADDRESS) 72 stream_reader = asyncio.StreamReader(loop=self.loop) 73 protocol = asyncio.StreamReaderProtocol(stream_reader, 77 self.assertIsInstance(trans, asyncio.Transport [all...] |
test_context.py | 1 import asyncio 13 await asyncio.sleep(t) 18 r1, r2 = await asyncio.gather( 23 r1, r2 = asyncio.run(main())
|
test_tasks.py | 18 import asyncio 19 from asyncio import coroutines 20 from asyncio import futures 21 from asyncio import tasks 27 @asyncio.coroutine 34 coroutines = asyncio.coroutines 103 @asyncio.coroutine 108 asyncio.gather(*[ 113 other_loop = asyncio.new_event_loop() 131 task = asyncio.ensure_future(test(), loop=self.loop [all...] |
test_queues.py | 6 import asyncio 34 q = asyncio.Queue(loop=loop) 40 q = asyncio.Queue(loop=loop) 42 asyncio.Task(q.get(), loop=loop) 44 await asyncio.sleep(0.1, loop=loop) 52 q = asyncio.Queue(maxsize=1, loop=loop) 55 asyncio.Task(q.put(2), loop=loop) 57 await asyncio.sleep(0.1, loop=loop) 64 q = asyncio.Queue(loop=loop) 70 q = asyncio.Queue(loop=loop [all...] |
test_streams.py | 18 import asyncio 28 self.loop = asyncio.new_event_loop() 39 @mock.patch('asyncio.streams.events') 41 stream = asyncio.StreamReader() 57 conn_fut = asyncio.open_connection(*httpd.address, 64 conn_fut = asyncio.open_unix_connection(httpd.address, 72 asyncio.set_event_loop(None) 83 conn_fut = asyncio.open_connection( 94 conn_fut = asyncio.open_unix_connection( 113 conn_fut = asyncio.open_connection(*httpd.address [all...] |
test_locks.py | 7 import asyncio 27 lock = asyncio.Lock(loop=loop) 30 lock = asyncio.Lock(loop=self.loop) 34 asyncio.set_event_loop(self.loop) 35 lock = asyncio.Lock() 39 lock = asyncio.Lock(loop=self.loop) 43 @asyncio.coroutine 53 lock = asyncio.Lock(loop=self.loop) 55 @asyncio.coroutine 69 loop = asyncio.new_event_loop() # don't use TestLoop quirk [all...] |
test_pep492.py | 10 import asyncio 14 # Test that asyncio.iscoroutine() uses collections.abc.Coroutine 33 self.loop = asyncio.BaseEventLoop() 44 asyncio.Lock(loop=self.loop), 45 asyncio.Condition(loop=self.loop), 46 asyncio.Semaphore(loop=self.loop), 47 asyncio.BoundedSemaphore(loop=self.loop), 51 await asyncio.sleep(0.01, loop=self.loop) 56 await asyncio.sleep(0.01, loop=self.loop) 66 asyncio.Lock(loop=self.loop) [all...] |
test_subprocess.py | 7 import asyncio 8 from asyncio import base_subprocess 9 from asyncio import subprocess 14 from asyncio import unix_events 52 waiter = asyncio.Future(loop=self.loop) 78 waiter = asyncio.Future(loop=self.loop) 107 proc = await asyncio.create_subprocess_exec( 124 task = asyncio.wait_for(task, 60.0, loop=self.loop) 133 proc = await asyncio.create_subprocess_exec( 142 task = asyncio.wait_for(task, 60.0, loop=self.loop [all...] |
test_buffered_proto.py | 1 import asyncio 7 class ReceiveStuffProto(asyncio.BufferedProtocol): 58 asyncio.start_server( 63 asyncio.wait_for(client(addr), 5, loop=self.loop)) 73 return asyncio.SelectorEventLoop() 76 @unittest.skipUnless(hasattr(asyncio, 'ProactorEventLoop'), 'Windows only') 81 return asyncio.ProactorEventLoop()
|
test_server.py | 1 import asyncio 45 srv = self.loop.run_until_complete(asyncio.start_server( 53 with self.assertRaises(asyncio.CancelledError): 70 return asyncio.SelectorEventLoop() 101 srv = self.loop.run_until_complete(asyncio.start_unix_server( 106 with self.assertRaises(asyncio.CancelledError): 120 @unittest.skipUnless(hasattr(asyncio, 'ProactorEventLoop'), 'Windows only') 124 return asyncio.ProactorEventLoop()
|
test_transports.py | 6 import asyncio 7 from asyncio import transports 13 transport = asyncio.Transport() 17 transport = asyncio.Transport({'extra': 'info'}) 25 transport = asyncio.Transport() 35 transport = asyncio.Transport() 50 transport = asyncio.DatagramTransport() 56 transport = asyncio.SubprocessTransport()
|
test_sslproto.py | 1 """Tests for asyncio/sslproto.py.""" 13 import asyncio 14 from asyncio import log 15 from asyncio import protocols 16 from asyncio import sslproto 17 from asyncio import tasks 27 self.loop = asyncio.new_event_loop() 33 proto = asyncio.Protocol() 50 with mock.patch('asyncio.sslproto._SSLPipe', return_value=sslpipe): 71 waiter = asyncio.Future(loop=self.loop [all...] |
test_events.py | 29 import asyncio 30 from asyncio import base_events 31 from asyncio import constants 32 from asyncio import coroutines 33 from asyncio import events 34 from asyncio import proactor_events 35 from asyncio import selector_events 55 loop = asyncio.new_event_loop() 56 asyncio.set_event_loop(loop) 74 class MyBaseProto(asyncio.Protocol) [all...] |
functional.py | 1 import asyncio 2 import asyncio.events 15 return asyncio.new_event_loop() 18 self.loop.run_until_complete(asyncio.sleep(delay, loop=self.loop)) 26 asyncio.set_event_loop(None) 32 self._old_get_running_loop = asyncio.events._get_running_loop 33 asyncio.events._get_running_loop = lambda: None 45 asyncio.events._get_running_loop = self._old_get_running_loop 46 asyncio.set_event_loop(None)
|
test_futures.py | 11 import asyncio 12 from asyncio import futures 89 g = asyncio.wrap_future(f) 94 g = asyncio.ensure_future(f) 115 self.assertFalse(asyncio.isfuture(MyFuture)) 116 self.assertTrue(asyncio.isfuture(MyFuture())) 117 self.assertFalse(asyncio.isfuture(1)) 120 self.assertFalse(asyncio.isfuture(mock.Mock())) 123 self.assertTrue(asyncio.isfuture(f)) 124 self.assertFalse(asyncio.isfuture(type(f)) [all...] |
test_base_events.py | 14 import asyncio 15 from asyncio import base_events 16 from asyncio import constants 17 from asyncio import events 46 return mock.patch('asyncio.base_events.socket', 190 f = asyncio.Future(loop=self.loop) 195 h = asyncio.Handle(lambda: False, (), self.loop, None) 202 h = asyncio.Handle(lambda: False, (), self.loop, None) 220 self.assertIsInstance(h, asyncio.Handle) 233 self.assertIsInstance(h, asyncio.TimerHandle [all...] |
test_selector_events.py | 13 import asyncio 14 from asyncio.selector_events import BaseSelectorEventLoop 15 from asyncio.selector_events import _SelectorTransport 16 from asyncio.selector_events import _SelectorSocketTransport 17 from asyncio.selector_events import _SelectorDatagramTransport 61 transport = self.loop._make_socket_transport(m, asyncio.Protocol()) 78 waiter = asyncio.Future(loop=self.loop) 81 m, asyncio.Protocol(), m, waiter) 108 @mock.patch('asyncio.selector_events.ssl', None) 109 @mock.patch('asyncio.sslproto.ssl', None [all...] |
test_proactor_events.py | 9 import asyncio 10 from asyncio import events 11 from asyncio.proactor_events import BaseProactorEventLoop 12 from asyncio.proactor_events import _ProactorSocketTransport 13 from asyncio.proactor_events import _ProactorWritePipeTransport 14 from asyncio.proactor_events import _ProactorDuplexPipeTransport 36 self.protocol = test_utils.make_test_protocol(asyncio.Protocol) 46 fut = asyncio.Future(loop=self.loop) 61 res = asyncio.Future(loop=self.loop) 71 res = asyncio.Future(loop=self.loop [all...] |
test_unix_events.py | 23 import asyncio 24 from asyncio import log 25 from asyncio import base_events 26 from asyncio import events 27 from asyncio import unix_events 48 self.loop = asyncio.SelectorEventLoop() 61 h = asyncio.Handle(mock.Mock(), (), 69 @mock.patch('asyncio.unix_events.signal') 79 @mock.patch('asyncio.unix_events.signal') 96 @mock.patch('asyncio.unix_events.signal' [all...] |
utils.py | 29 from asyncio import base_events 30 from asyncio import events 31 from asyncio import format_helpers 32 from asyncio import futures 33 from asyncio import tasks 34 from asyncio.log import logger 157 # between the stdlib and stand-alone asyncio. 508 # ensure that the event loop is passed explicitly in asyncio 542 """Context manager to disable asyncio logger.
|
/external/python/cpython3/Lib/test/ |
test_asyncgen.py | 6 asyncio = import_module("asyncio") variable 325 self.loop = asyncio.new_event_loop() 326 asyncio.set_event_loop(None) 341 await asyncio.sleep(0.01, loop=self.loop) 343 await asyncio.sleep(0.01, loop=self.loop) 353 await asyncio.sleep(0.01, loop=self.loop) 367 await asyncio.sleep(0.01, loop=loop) 376 await asyncio.sleep(0.01, loop=self.loop) 382 await asyncio.sleep(0.01, loop=self.loop [all...] |
test_contextlib_async.py | 1 import asyncio 15 loop = asyncio.new_event_loop() 16 asyncio.set_event_loop(loop) 21 asyncio.set_event_loop(None) 264 loop = asyncio.get_event_loop() 266 f = asyncio.ensure_future(coro) 295 self.loop = asyncio.new_event_loop() 296 asyncio.set_event_loop(self.loop)
|
/external/libchrome/third_party/jinja2/ |
asyncsupport.py | 13 import asyncio 54 return _convert_generator(self, asyncio.get_event_loop(), args, kwargs) 77 loop = asyncio.get_event_loop()
|
/external/ltp/android/include/ |
libaio.h | 48 #include <asyncio/AsyncIO.h>
|