Searched refs:run_until_complete (Results 1 – 25 of 41) sorted by relevance
12
/external/python/cpython3/Lib/test/test_asyncio/ |
D | test_streams.py | 52 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 …]
|
D | test_subprocess.py | 60 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 …]
|
D | test_queues.py | 55 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 …]
|
D | test_base_events.py | 196 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 …]
|
D | test_sock_lowlevel.py | 75 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 …]
|
D | test_tasks.py | 134 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 …]
|
D | test_events.py | 60 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 …]
|
D | test_threads.py | 22 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())
|
D | test_pep492.py | 65 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())
|
D | test_locks.py | 50 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 …]
|
D | test_server.py | 49 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())
|
D | test_windows_events.py | 71 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)
|
D | test_buffered_proto.py | 61 srv = self.loop.run_until_complete( 66 self.loop.run_until_complete( 70 self.loop.run_until_complete(srv.wait_closed())
|
D | test_sslproto.py | 275 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))
|
D | test_unix_events.py | 286 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 …]
|
D | utils.py | 105 loop.run_until_complete(t) 117 loop.run_until_complete(tasks.sleep(0.001)) 514 loop.run_until_complete(loop.shutdown_default_executor())
|
D | test_selector_events.py | 159 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)
|
D | functional.py | 19 self.loop.run_until_complete(asyncio.sleep(delay))
|
/external/python/cpython3/Lib/test/ |
D | test_asyncgen.py | 21 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/ |
D | runners.py | 44 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/ |
D | async_case.py | 80 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/ |
D | test_async.py | 20 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/ |
D | asyncsupport.py | 40 yield loop.run_until_complete(async_gen.__anext__()) 70 return loop.run_until_complete(self.render_async(*args, **kwargs))
|
/external/libchrome/third_party/jinja2/ |
D | asyncsupport.py | 48 yield loop.run_until_complete(async_gen.__anext__()) 78 return loop.run_until_complete(self.render_async(*args, **kwargs))
|
/external/mesa3d/bin/ |
D | gen_release_notes.py | 277 loop.run_until_complete(main())
|
12