Searched refs:run_until_complete (Results 1 – 25 of 31) sorted by relevance
12
45 reader, writer = self.loop.run_until_complete(open_connection_fut)48 data = self.loop.run_until_complete(f)51 data = self.loop.run_until_complete(f)70 reader, writer = self.loop.run_until_complete(open_connection_fut)75 data = self.loop.run_until_complete(f)103 reader, writer = self.loop.run_until_complete(open_connection_fut)107 self.loop.run_until_complete(f)141 data = self.loop.run_until_complete(stream.read(0))154 data = self.loop.run_until_complete(read_task)164 data = self.loop.run_until_complete(stream.read(5))[all …]
49 loop.run_until_complete(add_getter())62 loop.run_until_complete(add_putter())149 loop.run_until_complete(test())162 res = self.loop.run_until_complete(queue_get())172 res = self.loop.run_until_complete(q.get())206 res = loop.run_until_complete(queue_put())241 self.assertEqual(1, loop.run_until_complete(test()))263 self.assertEqual(self.loop.run_until_complete(q.get()), 'a')264 self.assertEqual(self.loop.run_until_complete(q.get()), 'b')281 self.loop.run_until_complete([all …]
55 self.loop.run_until_complete(waiter)81 self.loop.run_until_complete(waiter)125 exitcode, stdout = self.loop.run_until_complete(task)143 exitcode, stdout = self.loop.run_until_complete(task)150 proc = self.loop.run_until_complete(create)151 exitcode = self.loop.run_until_complete(proc.wait())159 proc = self.loop.run_until_complete(create)160 exitcode = self.loop.run_until_complete(proc.wait())166 proc = self.loop.run_until_complete(create)168 returncode = self.loop.run_until_complete(proc.wait())[all …]
192 self.assertRaises(RuntimeError, self.loop.run_until_complete, f)315 loop.run_until_complete(fut)480 self.loop.run_until_complete, 'blah')487 other_loop.run_until_complete, task)502 self.loop.run_until_complete(foo(0.1))508 self.loop.run_until_complete(foo(0.2))515 self.loop.run_until_complete, self.loop.subprocess_exec,520 self.loop.run_until_complete, self.loop.subprocess_exec,525 self.loop.run_until_complete, self.loop.subprocess_exec,530 self.loop.run_until_complete, self.loop.subprocess_exec,[all …]
107 self.loop.run_until_complete(122 self.loop.run_until_complete(run(fut))135 self.loop.run_until_complete(task)142 self.loop.run_until_complete(t)152 loop.run_until_complete(t)160 self.loop.run_until_complete(t)169 loop.run_until_complete(t)177 self.loop.run_until_complete(f)199 self.loop.run_until_complete(t)229 loop.run_until_complete(fut)[all …]
57 return loop.run_until_complete(doit())260 self.loop.run_until_complete(coro1())263 RuntimeError, self.loop.run_until_complete, coro2())270 self.loop.run_until_complete(asyncio.sleep(0.1, loop=self.loop))281 self.loop.run_until_complete, task)348 res, thread_id = self.loop.run_until_complete(f2)425 self.loop.run_until_complete(428 self.loop.run_until_complete(431 self.loop.run_until_complete(434 self.loop.run_until_complete([all …]
48 self.loop.run_until_complete(acquire_lock())60 res = self.loop.run_until_complete(acquire_lock())91 loop.run_until_complete(test(primitive))98 self.assertTrue(self.loop.run_until_complete(lock.acquire()))147 self.assertTrue(self.loop.run_until_complete(lock.acquire()))153 self.loop.run_until_complete, task)280 self.loop.run_until_complete(lock.acquire())294 with self.loop.run_until_complete(acquire_lock()):308 cm = self.loop.run_until_complete(acquire_lock())406 res = self.loop.run_until_complete(ev.wait())[all …]
61 self.loop.run_until_complete(test(primitive))84 self.loop.run_until_complete(test(primitive))103 data = self.loop.run_until_complete(reader())144 data = self.loop.run_until_complete(foo())149 data = self.loop.run_until_complete(foo())158 self.loop.run_until_complete(start())175 data = self.loop.run_until_complete(coro())193 self.loop.run_until_complete(runner())213 self.loop.run_until_complete(runner())
45 srv = self.loop.run_until_complete(asyncio.start_server(55 self.loop.run_until_complete(main_task)64 self.loop.run_until_complete(srv.serve_forever())101 srv = self.loop.run_until_complete(asyncio.start_unix_server(108 self.loop.run_until_complete(main_task)117 self.loop.run_until_complete(srv.serve_forever())
44 self.loop.run_until_complete(f)56 res = self.loop.run_until_complete(self._test_pipe())108 self.loop.run_until_complete(task)118 done = self.loop.run_until_complete(fut)133 done = self.loop.run_until_complete(fut)154 self.loop.run_until_complete(fut)
57 srv = self.loop.run_until_complete(62 self.loop.run_until_complete(66 self.loop.run_until_complete(srv.wait_closed())
270 self.loop.run_until_complete(360 self.loop.run_until_complete(422 self.loop.run_until_complete(507 self.loop.run_until_complete(run_main())518 self.loop.run_until_complete(main())555 self.loop.run_until_complete(client(srv.addr))593 self.loop.run_until_complete(client(srv.addr))629 self.loop.run_until_complete(client(srv.addr))671 res = self.loop.run_until_complete(client(srv.addr))
271 srv = self.loop.run_until_complete(coro)273 self.loop.run_until_complete(srv.wait_closed())280 srv = self.loop.run_until_complete(srv_coro)282 self.loop.run_until_complete(srv.wait_closed())291 self.loop.run_until_complete(coro)298 self.loop.run_until_complete(coro)305 self.loop.run_until_complete(coro)311 self.loop.run_until_complete(coro)320 self.loop.run_until_complete(coro)329 self.loop.run_until_complete(coro)[all …]
156 self.assertRaises(RuntimeError, self.loop.run_until_complete, f)193 self.loop.run_until_complete(asyncio.sleep(0.01, loop=self.loop))200 self.loop.run_until_complete(f)213 self.loop.run_until_complete(asyncio.sleep(0.01, loop=self.loop))224 self.loop.run_until_complete(asyncio.sleep(0.01, loop=self.loop))276 self.loop.run_until_complete(asyncio.sleep(0.01, loop=self.loop))284 self.loop.run_until_complete(f)291 self.loop.run_until_complete(asyncio.sleep(0, loop=self.loop))307 self.loop.run_until_complete(asyncio.sleep(0.01, loop=self.loop))318 self.loop.run_until_complete(asyncio.sleep(0.01, loop=self.loop))[all …]
104 loop.run_until_complete(t)116 loop.run_until_complete(tasks.sleep(0.001, loop=loop))
18 self.loop.run_until_complete(asyncio.sleep(delay, loop=self.loop))
439 res, ident = self.loop.run_until_complete(f2)
921 return self.loop.run_until_complete(coro)
21 def run_until_complete(coro): function44 return run_until_complete(iterate())347 res = self.loop.run_until_complete(self.to_list(gen()))359 self.loop.run_until_complete(self.to_list(gen()))370 res = loop.run_until_complete(self.to_list(Gen()))412 self.loop.run_until_complete(run1())413 self.loop.run_until_complete(run2())448 self.loop.run_until_complete(run())482 self.loop.run_until_complete(run())502 self.loop.run_until_complete(run())[all …]
18 return loop.run_until_complete(coro)
43 return loop.run_until_complete(main)47 loop.run_until_complete(loop.shutdown_asyncgens())61 loop.run_until_complete(
219 def run_until_complete(self, future): member in AbstractEventLoop
48 yield loop.run_until_complete(async_gen.__anext__())78 return loop.run_until_complete(self.render_async(*args, **kwargs))
47 * - :meth:`loop.run_until_complete`
99 .. method:: loop.run_until_complete(future)122 :meth:`run_until_complete` is called.165 loop.run_until_complete(loop.shutdown_asyncgens())