| /dports/www/py-tornado/tornado-6.1/tornado/test/ |
| H A D | locks_test.py | 184 future = asyncio.ensure_future(c.wait())
208 future_0 = asyncio.ensure_future(e.wait())
210 future_1 = asyncio.ensure_future(e.wait())
212 future_2 = asyncio.ensure_future(e.wait())
236 f0 = asyncio.ensure_future(e.wait())
238 f1 = asyncio.ensure_future(e.wait())
260 f0 = asyncio.ensure_future(sem.acquire())
264 f1 = asyncio.ensure_future(sem.acquire())
266 f2 = asyncio.ensure_future(sem.acquire())
290 f = asyncio.ensure_future(sem.acquire())
[all …]
|
| /dports/www/py-autobahn/autobahn-python-19.5.1/autobahn/asyncio/ |
| H A D | websocket.py | 52 ensure_future = asyncio.ensure_future variable
129 ensure_future(res)
134 ensure_future(res)
139 ensure_future(res)
144 ensure_future(res)
149 ensure_future(res)
154 ensure_future(res)
159 ensure_future(res)
164 ensure_future(res)
169 ensure_future(res)
[all …]
|
| /dports/net/pyrad/pyrad-2.4/example/ |
| H A D | auth_async.py | 51 asyncio.ensure_future(
73 loop.run_until_complete(asyncio.ensure_future(
96 loop.run_until_complete(asyncio.ensure_future(
105 loop.run_until_complete(asyncio.ensure_future(
117 asyncio.ensure_future(
133 loop.run_until_complete(asyncio.ensure_future(
149 loop.run_until_complete(asyncio.ensure_future(
158 loop.run_until_complete(asyncio.ensure_future(
|
| /dports/devel/py-prompt-toolkit2/prompt_toolkit-2.0.10/tests/ |
| H A D | test_async_generator.py | 8 ensure_future,
33 f = ensure_future(consume_async_generator(
53 f = ensure_future(consume_async_generator(
77 f = ensure_future(consume_async_generator(
|
| /dports/databases/py-asyncpg/asyncpg-0.25.0/asyncpg/_testbase/ |
| H A D | fuzzer.py | 39 work_task = asyncio.ensure_future(work)
40 stop_event_task = asyncio.ensure_future(self.stop_event.wait())
95 self.listen_task = asyncio.ensure_future(self.listen())
182 self.proxy_to_backend_task = asyncio.ensure_future(
185 self.proxy_from_backend_task = asyncio.ensure_future(
213 read_task = asyncio.ensure_future(
215 conn_event_task = asyncio.ensure_future(
235 write_task = asyncio.ensure_future(
237 conn_event_task = asyncio.ensure_future(
|
| /dports/www/py-tornado4/tornado-4.5.3/tornado/test/ |
| H A D | asyncio_test.py | 47 ensure_future = asyncio.ensure_future
49 ensure_future = asyncio.async
51 x = yield ensure_future(
|
| /dports/databases/py-aioredis/aioredis-1.3.1/tests/ |
| H A D | locks_test.py | 9 ta = asyncio.ensure_future(lock.acquire())
13 tb = asyncio.ensure_future(lock.acquire())
20 asyncio.ensure_future(lock.acquire())
|
| /dports/devel/py-graphql-core2/graphql-core-2.2.1/graphql/execution/executors/ |
| H A D | asyncio_utils.py | 2 from asyncio import ensure_future, wait, CancelledError
8 task = ensure_future(iterate_asyncgen(asyncgen, observer), loop=loop)
15 ensure_future(await_task(), loop=loop)
|
| /dports/sysutils/py-salt/salt-3004.1/salt/ext/tornado/test/ |
| H A D | asyncio_test.py | 48 ensure_future = asyncio.ensure_future
51 ensure_future = getattr(asyncio, "async")
53 x = yield ensure_future(
|
| /dports/devel/py-pyee/pyee-8.2.2/pyee/ |
| H A D | _asyncio.py | 3 from asyncio import ensure_future, Future, iscoroutine
47 f = ensure_future(coro, loop=self._loop)
49 f = ensure_future(coro)
|
| H A D | _compat.py | 5 from asyncio import iscoroutine, ensure_future
8 ensure_future = None variable
34 def __init__(self, scheduler=ensure_future, loop=None):
|
| /dports/lang/clover/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/libosmesa-gallium/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/libosmesa/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-gallium-va/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-dri-gallium/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-gallium-vdpau/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-gallium-xa/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-libs/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-dri/mesa-21.3.6/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-devel/mesa-22.0-branchpoint-2059-ge8a63cf61ec/bin/pick/ |
| H A D | ui.py | 54 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/graphics/mesa-dri-classic/mesa-20.2.3/bin/pick/ |
| H A D | ui.py | 55 asyncio.ensure_future(self.ui.update())
94 asyncio.ensure_future(self.apply())
96 asyncio.ensure_future(self.denominate())
98 asyncio.ensure_future(self.backport())
145 asyncio.ensure_future(self.update())
218 urwid.connect_signal(ok_btn, 'click', lambda _: asyncio.ensure_future(apply_cb(q)))
249 … can_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.abort_cherry(self, err)))
254 ok_btn, 'click', lambda _: asyncio.ensure_future(commit.commit.resolve(self)))
|
| /dports/databases/py-motor/motor-1.0/test/asyncio_tests/ |
| H A D | __init__.py | 26 from asyncio import ensure_future
28 from asyncio import async as ensure_future
162 def ensure_future(self, coro): member in AsyncIOMockServerTestCase
163 return ensure_future(coro, loop=self.loop)
170 return self.ensure_future(fetch_next())
227 task = ensure_future(coro, loop=self.loop)
|
| /dports/devel/py-prompt-toolkit2/prompt_toolkit-2.0.10/prompt_toolkit/application/ |
| H A D | run_in_terminal.py | 10 ensure_future,
70 return ensure_future(async_func())
117 return ensure_future(_run_in_t())
|
| /dports/devel/py-lineedit/lineedit-0.1.6/lineedit/deps/prompt_toolkit/application/ |
| H A D | run_in_terminal.py | 10 ensure_future,
70 return ensure_future(async_func())
117 return ensure_future(_run_in_t())
|