/third_party/python/Lib/test/test_asyncio/ |
H A D | test_streams.py | 46 reader, writer = self.loop.run_until_complete(open_connection_fut) 49 data = self.loop.run_until_complete(f) 52 data = self.loop.run_until_complete(f) 72 reader, writer = self.loop.run_until_complete(open_connection_fut) 77 data = self.loop.run_until_complete(f) 107 reader, writer = self.loop.run_until_complete(open_connection_fut) 111 self.loop.run_until_complete(f) 144 data = self.loop.run_until_complete(stream.read(0)) 157 data = self.loop.run_until_complete(read_task) 167 data = self.loop.run_until_complete(strea [all...] |
H A D | test_subprocess.py | 63 self.loop.run_until_complete(waiter) 89 self.loop.run_until_complete(waiter) 133 exitcode, stdout = self.loop.run_until_complete(task) 151 exitcode, stdout = self.loop.run_until_complete(task) 156 proc = self.loop.run_until_complete( 159 exitcode = self.loop.run_until_complete(proc.wait()) 164 proc = self.loop.run_until_complete( 170 exitcode = self.loop.run_until_complete(proc.wait()) 175 proc = self.loop.run_until_complete( 179 returncode = self.loop.run_until_complete(pro [all...] |
H A D | test_base_events.py | 195 self.assertRaises(RuntimeError, self.loop.run_until_complete, f) 339 loop.run_until_complete(fut) 479 self.loop.run_until_complete, 'blah') 486 other_loop.run_until_complete, task) 501 self.loop.run_until_complete(foo(0.1)) 503 # This call fails if run_until_complete does not clean up 505 self.loop.run_until_complete(foo(0.2)) 512 self.loop.run_until_complete, self.loop.subprocess_exec, 517 self.loop.run_until_complete, self.loop.subprocess_exec, 522 self.loop.run_until_complete, sel [all...] |
H A D | test_events.py | 62 return loop.run_until_complete(doit()) 283 self.loop.run_until_complete(coro1()) 290 RuntimeError, self.loop.run_until_complete, coro2()) 297 self.loop.run_until_complete(asyncio.sleep(0.1)) 308 self.loop.run_until_complete, task) 372 res, thread_id = self.loop.run_until_complete(f2) 388 self.loop.run_until_complete( 528 tr, pr = self.loop.run_until_complete(connection_fut) 534 self.loop.run_until_complete(pr.done) 590 tr, pr = self.loop.run_until_complete(connection_fu [all...] |
H A D | test_sock_lowlevel.py | 82 self.loop.run_until_complete( 85 self.loop.run_until_complete( 88 self.loop.run_until_complete( 91 self.loop.run_until_complete( 94 self.loop.run_until_complete( 99 self.loop.run_until_complete( 101 self.loop.run_until_complete( 103 data = self.loop.run_until_complete( 106 self.loop.run_until_complete( 114 self.loop.run_until_complete( [all...] |
H A D | test_tasks.py | 120 self.loop.run_until_complete(t) 133 self.loop.run_until_complete(t) 145 self.loop.run_until_complete( 160 self.loop.run_until_complete(run(fut)) 173 self.loop.run_until_complete(task) 179 self.loop.run_until_complete(t) 189 loop.run_until_complete(t) 197 self.loop.run_until_complete(t) 208 t = self.loop.run_until_complete(test()) 210 self.loop.run_until_complete( [all...] |
H A D | test_pep492.py | 64 self.loop.run_until_complete(test(primitive)) 86 self.loop.run_until_complete(test(primitive)) 105 data = self.loop.run_until_complete(reader()) 133 data = self.loop.run_until_complete(foo()) 138 data = self.loop.run_until_complete(foo()) 147 self.loop.run_until_complete(start()) 164 data = self.loop.run_until_complete(coro()) 182 self.loop.run_until_complete(runner()) 202 self.loop.run_until_complete(runner())
|
H A D | test_server.py | 48 srv = self.loop.run_until_complete(asyncio.start_server( 58 self.loop.run_until_complete(main_task) 67 self.loop.run_until_complete(srv.serve_forever()) 104 srv = self.loop.run_until_complete(asyncio.start_unix_server( 111 self.loop.run_until_complete(main_task) 120 self.loop.run_until_complete(srv.serve_forever())
|
H A 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) 254 res = self.loop.run_until_complete(self._test_client_pipe_stat())
|
H A 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())
|
H A D | test_ssl.py | 282 self.loop.run_until_complete(start_server()) 377 self.loop.run_until_complete(_gather(*tasks)) 418 self.loop.run_until_complete(client(srv.addr)) 455 self.loop.run_until_complete(client(srv.addr)) 492 self.loop.run_until_complete(client(srv.addr)) 538 self.loop.run_until_complete(client(srv.addr)) 630 self.loop.run_until_complete(asyncio.sleep(0.1)) 674 res = self.loop.run_until_complete(client(srv.addr)) 735 self.loop.run_until_complete( 794 self.loop.run_until_complete( [all...] |
H A D | test_sslproto.py | 280 self.loop.run_until_complete( 343 self.loop.run_until_complete( 440 self.loop.run_until_complete( 501 self.loop.run_until_complete( 592 self.loop.run_until_complete(run_main()) 603 self.loop.run_until_complete(main()) 639 self.loop.run_until_complete(client(srv.addr)) 682 self.loop.run_until_complete(client(srv.addr)) 717 self.loop.run_until_complete(client(srv.addr)) 758 res = self.loop.run_until_complete(clien [all...] |
H A D | test_unix_events.py | 295 srv = self.loop.run_until_complete(coro) 297 self.loop.run_until_complete(srv.wait_closed()) 304 srv = self.loop.run_until_complete(srv_coro) 306 self.loop.run_until_complete(srv.wait_closed()) 315 self.loop.run_until_complete(coro) 322 self.loop.run_until_complete(coro) 329 self.loop.run_until_complete(coro) 335 self.loop.run_until_complete(coro) 344 self.loop.run_until_complete(coro) 353 self.loop.run_until_complete(cor [all...] |
H A D | utils.py | 102 # Don't log a warning if the task is not done after run_until_complete(). 106 loop.run_until_complete(t) 118 loop.run_until_complete(tasks.sleep(0.001)) 541 loop.run_until_complete(loop.shutdown_default_executor())
|
H A D | test_selector_events.py | 121 self.assertRaises(RuntimeError, self.loop.run_until_complete, f) 164 self.loop.run_until_complete(con) 168 self.loop.run_until_complete(con) 355 self.loop.run_until_complete(asyncio.sleep(0)) 501 self.loop.run_until_complete(waiter) 510 self.loop.run_until_complete(waiter) 879 self.loop.run_until_complete(asyncio.sleep(0)) 913 self.loop.run_until_complete(waiter)
|
H A D | test_futures.py | 154 f = self.loop.run_until_complete(test()) 229 self.loop.run_until_complete(f) 240 self.loop.run_until_complete(f) 482 res, ident = self.loop.run_until_complete(f2) 509 f2 = self.loop.run_until_complete(test())
|
H A D | functional.py | 19 self.loop.run_until_complete(asyncio.sleep(delay))
|
H A D | test_sendfile.py | 137 return self.loop.run_until_complete(coro) 529 self.loop.run_until_complete(
|
/third_party/python/Lib/test/ |
H A D | test_asyncgen.py | 28 def run_until_complete(coro): function 51 return run_until_complete(iterate()) 427 res = self.loop.run_until_complete(consume()) 430 self.loop.run_until_complete(consume()) 449 result = self.loop.run_until_complete(test_2()) 467 result = self.loop.run_until_complete(test_throw()) 517 res = self.loop.run_until_complete(consume()) 534 self.loop.run_until_complete(consume()) 556 self.loop.run_until_complete(call_with_too_few_args()) 558 self.loop.run_until_complete(call_with_too_many_arg [all...] |
/third_party/python/Lib/asyncio/ |
H A D | runners.py | 72 loop.run_until_complete(loop.shutdown_asyncgens()) 73 loop.run_until_complete(loop.shutdown_default_executor()) 118 return self._loop.run_until_complete(task) 201 loop.run_until_complete(tasks.gather(*to_cancel, return_exceptions=True))
|
/third_party/jinja2/ |
H A D | asyncsupport.py | 43 yield loop.run_until_complete(async_gen.__anext__()) 73 return loop.run_until_complete(self.render_async(*args, **kwargs))
|
/third_party/node/deps/v8/third_party/jinja2/ |
H A D | asyncsupport.py | 43 yield loop.run_until_complete(async_gen.__anext__()) 73 return loop.run_until_complete(self.render_async(*args, **kwargs))
|
/third_party/node/tools/inspector_protocol/jinja2/ |
H A D | asyncsupport.py | 48 yield loop.run_until_complete(async_gen.__anext__()) 78 return loop.run_until_complete(self.render_async(*args, **kwargs))
|
/third_party/skia/third_party/externals/jinja2/ |
H A D | asyncsupport.py | 43 yield loop.run_until_complete(async_gen.__anext__()) 73 return loop.run_until_complete(self.render_async(*args, **kwargs))
|
/third_party/mesa3d/bin/ |
H A D | gen_release_notes.py | 342 loop.run_until_complete(main())
|