Home
last modified time | relevance | path

Searched refs:run_until_complete (Results 1 - 25 of 30) sorted by relevance

12

/third_party/python/Lib/test/test_asyncio/
H A Dtest_streams.py46 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 Dtest_subprocess.py63 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 Dtest_base_events.py195 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 Dtest_events.py62 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 Dtest_sock_lowlevel.py82 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 Dtest_tasks.py120 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 Dtest_pep492.py64 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 Dtest_server.py48 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 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)
254 res = self.loop.run_until_complete(self._test_client_pipe_stat())
H A 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())
H A Dtest_ssl.py282 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 Dtest_sslproto.py280 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 Dtest_unix_events.py295 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 Dutils.py102 # 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 Dtest_selector_events.py121 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 Dtest_futures.py154 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 Dfunctional.py19 self.loop.run_until_complete(asyncio.sleep(delay))
H A Dtest_sendfile.py137 return self.loop.run_until_complete(coro)
529 self.loop.run_until_complete(
/third_party/python/Lib/test/
H A Dtest_asyncgen.py28 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 Drunners.py72 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 Dasyncsupport.py43 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 Dasyncsupport.py43 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 Dasyncsupport.py48 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 Dasyncsupport.py43 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 Dgen_release_notes.py342 loop.run_until_complete(main())

Completed in 21 milliseconds

12