| /dports/databases/py-cassandra-driver/cassandra-driver-3.18.0/cassandra/io/ |
| H A D | asyncioreactor.py | 21 asyncio.run_coroutine_threadsafe
46 self._handle = asyncio.run_coroutine_threadsafe(delayed, loop=loop)
97 self._read_watcher = asyncio.run_coroutine_threadsafe(
100 self._write_watcher = asyncio.run_coroutine_threadsafe(
133 asyncio.run_coroutine_threadsafe(
167 asyncio.run_coroutine_threadsafe(
|
| /dports/devel/py-yappi/yappi-1.3.3/tests/ |
| H A D | test_asyncio.py | 141 fut = asyncio.run_coroutine_threadsafe(a(), ts[0]._loop)
143 fut = asyncio.run_coroutine_threadsafe(recursive_a(5), ts[1]._loop)
145 fut = asyncio.run_coroutine_threadsafe(b(), ts[2]._loop)
152 asyncio.run_coroutine_threadsafe(stop_loop(), t._loop)
|
| /dports/net/py-zeroconf/python-zeroconf-0.37.0/zeroconf/_utils/ |
| H A D | asyncio.py | 107 return asyncio.run_coroutine_threadsafe(aw, loop).result(
117 … asyncio.run_coroutine_threadsafe(_async_get_all_tasks(loop), loop).result(_GET_ALL_TASKS_TIMEOUT)
121 asyncio.run_coroutine_threadsafe(_wait_for_loop_tasks(pending_tasks), loop).result(
|
| /dports/net/py-zeroconf/python-zeroconf-0.37.0/tests/ |
| H A D | __init__.py | 42 asyncio.run_coroutine_threadsafe(_wait_for_response(), zc.loop).result()
53 asyncio.run_coroutine_threadsafe(zc.async_wait_for_start(), zc.loop).result()
|
| /dports/devel/grpc130/grpc-1.30.2/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| H A D | common.pyx.pxi | 109 return asyncio.run_coroutine_threadsafe(
121 future = asyncio.run_coroutine_threadsafe(
150 asyncio.run_coroutine_threadsafe(queue.put(item), loop).result()
152 asyncio.run_coroutine_threadsafe(queue.put(EOF), loop).result()
|
| /dports/finance/electrum/Electrum-4.1.5/electrum/plugins/labels/ |
| H A D | labels.py | 74 … asyncio.run_coroutine_threadsafe(self.do_post_safe("/label", bundle), wallet.network.asyncio_loop)
171 …return asyncio.run_coroutine_threadsafe(self.pull_thread(wallet, force), wallet.network.asyncio_lo…
175 …return asyncio.run_coroutine_threadsafe(self.push_thread(wallet), wallet.network.asyncio_loop).res…
190 …asyncio.run_coroutine_threadsafe(self.pull_safe_thread(wallet, False), wallet.network.asyncio_loop)
|
| /dports/devel/grpc/grpc-1.42.0/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| H A D | common.pyx.pxi | 111 return asyncio.run_coroutine_threadsafe(
123 future = asyncio.run_coroutine_threadsafe(
152 asyncio.run_coroutine_threadsafe(queue.put(item), loop).result()
154 asyncio.run_coroutine_threadsafe(queue.put(EOF), loop).result()
|
| /dports/devel/grpc134/grpc-1.34.1/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| H A D | common.pyx.pxi | 111 return asyncio.run_coroutine_threadsafe(
123 future = asyncio.run_coroutine_threadsafe(
152 asyncio.run_coroutine_threadsafe(queue.put(item), loop).result()
154 asyncio.run_coroutine_threadsafe(queue.put(EOF), loop).result()
|
| /dports/devel/py-grpcio/grpcio-1.43.0/src/python/grpcio/grpc/_cython/_cygrpc/aio/ |
| H A D | common.pyx.pxi | 113 return asyncio.run_coroutine_threadsafe(
125 future = asyncio.run_coroutine_threadsafe(
154 asyncio.run_coroutine_threadsafe(queue.put(item), loop).result()
156 asyncio.run_coroutine_threadsafe(queue.put(EOF), loop).result()
|
| /dports/devel/py-aiortc/aiortc-1.2.1/src/aiortc/contrib/ |
| H A D | media.py | 110 asyncio.run_coroutine_threadsafe(audio_track._queue.put(None), loop)
112 asyncio.run_coroutine_threadsafe(video_track._queue.put(None), loop)
140 asyncio.run_coroutine_threadsafe(
158 asyncio.run_coroutine_threadsafe(video_track._queue.put(frame), loop)
|
| /dports/finance/electrum/Electrum-4.1.5/electrum/scripts/ |
| H A D | servers.py | 27 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | get_history.py | 33 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | block_headers.py | 38 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | txbroadcast.py | 36 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | estimate_fee.py | 30 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | peers.py | 29 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | txradar.py | 38 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | bip39_recovery.py | 40 asyncio.run_coroutine_threadsafe(f(), loop)
|
| H A D | watch_address.py | 47 asyncio.run_coroutine_threadsafe(notifier.watch_queue.put(addr), loop)
|
| /dports/devel/pytype/pytype-2021.9.9/pytype/typeshed/stdlib/asyncio/ |
| H A D | __init__.pyi | 59 run_coroutine_threadsafe as run_coroutine_threadsafe,
|
| /dports/devel/py-jedi/jedi-0.18.0/jedi/third_party/typeshed/stdlib/3/asyncio/ |
| H A D | __init__.pyi | 45 run_coroutine_threadsafe as run_coroutine_threadsafe,
|
| /dports/devel/py-mypy/mypy-0.910/mypy/typeshed/stdlib/asyncio/ |
| H A D | __init__.pyi | 59 run_coroutine_threadsafe as run_coroutine_threadsafe,
|
| /dports/finance/electrum/Electrum-4.1.5/electrum/gui/kivy/uix/dialogs/ |
| H A D | lightning_channels.py | 435 …coro = asyncio.run_coroutine_threadsafe(self.app.wallet.lnworker.request_force_close(self.chan.cha…
525 f = asyncio.run_coroutine_threadsafe(coro, loop)
588 …coro = asyncio.run_coroutine_threadsafe(self.app.wallet.lnworker.force_close_channel(self.chan.cha…
832 asyncio.run_coroutine_threadsafe(coro, loop)
842 asyncio.run_coroutine_threadsafe(coro, loop)
|
| /dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/typeshed/stdlib/3/asyncio/ |
| H A D | __init__.pyi | 98 run_coroutine_threadsafe as run_coroutine_threadsafe,
|
| /dports/finance/electrum/Electrum-4.1.5/electrum/ |
| H A D | lnrater.py | 90 fut = asyncio.run_coroutine_threadsafe(self._maybe_analyze_graph(), loop)
97 fut = asyncio.run_coroutine_threadsafe(self._analyze_graph(), loop)
|