Home
last modified time | relevance | path

Searched refs:run_until_complete (Results 1 – 25 of 41) sorted by relevance

12

/external/python/cpython3/Lib/test/test_asyncio/
Dtest_streams.py52 reader, writer = self.loop.run_until_complete(open_connection_fut)
55 data = self.loop.run_until_complete(f)
58 data = self.loop.run_until_complete(f)
81 reader, writer = self.loop.run_until_complete(open_connection_fut)
86 data = self.loop.run_until_complete(f)
118 reader, writer = self.loop.run_until_complete(open_connection_fut)
122 self.loop.run_until_complete(f)
157 data = self.loop.run_until_complete(stream.read(0))
170 data = self.loop.run_until_complete(read_task)
180 data = self.loop.run_until_complete(stream.read(5))
[all …]
Dtest_subprocess.py60 self.loop.run_until_complete(waiter)
86 self.loop.run_until_complete(waiter)
130 exitcode, stdout = self.loop.run_until_complete(task)
148 exitcode, stdout = self.loop.run_until_complete(task)
153 proc = self.loop.run_until_complete(
156 exitcode = self.loop.run_until_complete(proc.wait())
161 proc = self.loop.run_until_complete(
167 exitcode = self.loop.run_until_complete(proc.wait())
172 proc = self.loop.run_until_complete(
176 returncode = self.loop.run_until_complete(proc.wait())
[all …]
Dtest_queues.py55 loop.run_until_complete(add_getter())
69 loop.run_until_complete(add_putter())
162 loop.run_until_complete(test())
176 res = self.loop.run_until_complete(queue_get())
187 res = self.loop.run_until_complete(q.get())
222 res = loop.run_until_complete(queue_put())
260 self.assertEqual(1, loop.run_until_complete(test()))
284 self.assertEqual(self.loop.run_until_complete(q.get()), 'a')
285 self.assertEqual(self.loop.run_until_complete(q.get()), 'b')
304 self.loop.run_until_complete(
[all …]
Dtest_base_events.py196 self.assertRaises(RuntimeError, self.loop.run_until_complete, f)
336 loop.run_until_complete(fut)
476 self.loop.run_until_complete, 'blah')
483 other_loop.run_until_complete, task)
498 self.loop.run_until_complete(foo(0.1))
502 self.loop.run_until_complete(foo(0.2))
509 self.loop.run_until_complete, self.loop.subprocess_exec,
514 self.loop.run_until_complete, self.loop.subprocess_exec,
519 self.loop.run_until_complete, self.loop.subprocess_exec,
524 self.loop.run_until_complete, self.loop.subprocess_exec,
[all …]
Dtest_sock_lowlevel.py75 self.loop.run_until_complete(
78 self.loop.run_until_complete(
81 self.loop.run_until_complete(
84 self.loop.run_until_complete(
87 self.loop.run_until_complete(
92 self.loop.run_until_complete(
94 self.loop.run_until_complete(
96 data = self.loop.run_until_complete(
99 self.loop.run_until_complete(
107 self.loop.run_until_complete(
[all …]
Dtest_tasks.py134 self.loop.run_until_complete(t)
145 self.loop.run_until_complete(t)
155 self.loop.run_until_complete(
170 self.loop.run_until_complete(run(fut))
183 self.loop.run_until_complete(task)
189 self.loop.run_until_complete(t)
199 loop.run_until_complete(t)
208 self.loop.run_until_complete(t)
217 loop.run_until_complete(t)
225 self.loop.run_until_complete(f)
[all …]
Dtest_events.py60 return loop.run_until_complete(doit())
261 self.loop.run_until_complete(coro1())
268 RuntimeError, self.loop.run_until_complete, coro2())
275 self.loop.run_until_complete(asyncio.sleep(0.1))
286 self.loop.run_until_complete, task)
350 res, thread_id = self.loop.run_until_complete(f2)
366 self.loop.run_until_complete(
502 tr, pr = self.loop.run_until_complete(connection_fut)
508 self.loop.run_until_complete(pr.done)
564 tr, pr = self.loop.run_until_complete(connection_fut)
[all …]
Dtest_threads.py22 self.loop.run_until_complete(
33 result = self.loop.run_until_complete(main())
44 self.loop.run_until_complete(main())
52 self.loop.run_until_complete(main())
65 self.loop.run_until_complete(main())
75 self.loop.run_until_complete(main())
88 result = self.loop.run_until_complete(main())
Dtest_pep492.py65 self.loop.run_until_complete(test(primitive))
88 self.loop.run_until_complete(test(primitive))
107 data = self.loop.run_until_complete(reader())
149 data = self.loop.run_until_complete(foo())
154 data = self.loop.run_until_complete(foo())
163 self.loop.run_until_complete(start())
180 data = self.loop.run_until_complete(coro())
198 self.loop.run_until_complete(runner())
218 self.loop.run_until_complete(runner())
Dtest_locks.py50 self.loop.run_until_complete(lock.acquire())
66 self.loop.run_until_complete(acquire_lock())
94 loop.run_until_complete(test(primitive))
102 self.assertTrue(self.loop.run_until_complete(lock.acquire()))
152 self.assertTrue(self.loop.run_until_complete(lock.acquire()))
158 self.loop.run_until_complete, task)
290 self.loop.run_until_complete(lock.acquire())
306 self.loop.run_until_complete(f())
388 res = self.loop.run_until_complete(ev.wait())
399 self.loop.run_until_complete, wait)
[all …]
Dtest_server.py49 srv = self.loop.run_until_complete(asyncio.start_server(
59 self.loop.run_until_complete(main_task)
68 self.loop.run_until_complete(srv.serve_forever())
106 srv = self.loop.run_until_complete(asyncio.start_unix_server(
113 self.loop.run_until_complete(main_task)
122 self.loop.run_until_complete(srv.serve_forever())
Dtest_windows_events.py71 loop.run_until_complete(coro())
94 self.loop.run_until_complete(f)
106 res = self.loop.run_until_complete(self._test_pipe())
158 self.loop.run_until_complete(task)
168 done = self.loop.run_until_complete(fut)
183 done = self.loop.run_until_complete(fut)
204 self.loop.run_until_complete(fut)
236 self.loop.run_until_complete(f)
Dtest_buffered_proto.py61 srv = self.loop.run_until_complete(
66 self.loop.run_until_complete(
70 self.loop.run_until_complete(srv.wait_closed())
Dtest_sslproto.py275 self.loop.run_until_complete(
337 self.loop.run_until_complete(
433 self.loop.run_until_complete(
494 self.loop.run_until_complete(
585 self.loop.run_until_complete(run_main())
596 self.loop.run_until_complete(main())
632 self.loop.run_until_complete(client(srv.addr))
676 self.loop.run_until_complete(client(srv.addr))
713 self.loop.run_until_complete(client(srv.addr))
756 res = self.loop.run_until_complete(client(srv.addr))
Dtest_unix_events.py286 srv = self.loop.run_until_complete(coro)
288 self.loop.run_until_complete(srv.wait_closed())
295 srv = self.loop.run_until_complete(srv_coro)
297 self.loop.run_until_complete(srv.wait_closed())
306 self.loop.run_until_complete(coro)
313 self.loop.run_until_complete(coro)
320 self.loop.run_until_complete(coro)
326 self.loop.run_until_complete(coro)
335 self.loop.run_until_complete(coro)
344 self.loop.run_until_complete(coro)
[all …]
Dutils.py105 loop.run_until_complete(t)
117 loop.run_until_complete(tasks.sleep(0.001))
514 loop.run_until_complete(loop.shutdown_default_executor())
Dtest_selector_events.py159 self.assertRaises(RuntimeError, self.loop.run_until_complete, f)
375 self.loop.run_until_complete(asyncio.sleep(0))
521 self.loop.run_until_complete(waiter)
530 self.loop.run_until_complete(waiter)
882 self.loop.run_until_complete(asyncio.sleep(0))
916 self.loop.run_until_complete(waiter)
Dfunctional.py19 self.loop.run_until_complete(asyncio.sleep(delay))
/external/python/cpython3/Lib/test/
Dtest_asyncgen.py21 def run_until_complete(coro): function
44 return run_until_complete(iterate())
390 res = self.loop.run_until_complete(self.to_list(gen()))
402 self.loop.run_until_complete(self.to_list(gen()))
413 res = loop.run_until_complete(self.to_list(Gen()))
455 self.loop.run_until_complete(run1())
456 self.loop.run_until_complete(run2())
491 self.loop.run_until_complete(run())
525 self.loop.run_until_complete(run())
545 self.loop.run_until_complete(run())
[all …]
/external/python/cpython3/Lib/asyncio/
Drunners.py44 return loop.run_until_complete(main)
48 loop.run_until_complete(loop.shutdown_asyncgens())
49 loop.run_until_complete(loop.shutdown_default_executor())
63 loop.run_until_complete(
/external/python/cpython3/Lib/unittest/
Dasync_case.py80 return self._asyncioTestLoop.run_until_complete(fut)
88 return self._asyncioTestLoop.run_until_complete(fut)
119 loop.run_until_complete(fut)
126 loop.run_until_complete(self._asyncioCallsQueue.join())
137 loop.run_until_complete(
150 loop.run_until_complete(loop.shutdown_asyncgens())
/external/python/pybind11/tests/
Dtest_async.py20 assert 5 == event_loop.run_until_complete(get_await_result(m.SupportsAsync()))
25 event_loop.run_until_complete(get_await_result(m.DoesNotSupportAsync()))
/external/python/jinja/src/jinja2/
Dasyncsupport.py40 yield loop.run_until_complete(async_gen.__anext__())
70 return loop.run_until_complete(self.render_async(*args, **kwargs))
/external/libchrome/third_party/jinja2/
Dasyncsupport.py48 yield loop.run_until_complete(async_gen.__anext__())
78 return loop.run_until_complete(self.render_async(*args, **kwargs))
/external/mesa3d/bin/
Dgen_release_notes.py277 loop.run_until_complete(main())

12