| /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>
|
