| /dports/net/py-confluent-kafka/confluent-kafka-1.2.0/tests/ |
| H A D | test_Admin.py | 68 for f in concurrent.futures.as_completed(iter(fs.values())):
75 for f in concurrent.futures.as_completed(iter(fs.values())):
87 for f in concurrent.futures.as_completed(iter(fs.values())):
138 for f in concurrent.futures.as_completed(iter(fs.values())):
144 for f in concurrent.futures.as_completed(iter(fs.values())):
180 for f in concurrent.futures.as_completed(iter(fs.values())):
191 for f in concurrent.futures.as_completed(iter(fs.values())):
223 for f in concurrent.futures.as_completed(iter(fs.values())):
255 for f in concurrent.futures.as_completed(iter(fs.values())):
|
| /dports/net-p2p/bazarr/bazarr-1.0.2/libs/tqdm/ |
| H A D | asyncio.py | 58 def as_completed(cls, fs, *, loop=None, timeout=None, total=None, **tqdm_kwargs):
67 yield from cls(asyncio.as_completed(fs, timeout=timeout, **kwargs),
79 res = [await f for f in cls.as_completed(ifs, loop=loop, timeout=timeout,
|
| /dports/www/firefox/firefox-99.0/third_party/python/tqdm/tqdm/ |
| H A D | asyncio.py | 58 def as_completed(cls, fs, *, loop=None, timeout=None, total=None, **tqdm_kwargs): member in tqdm_asyncio
67 yield from cls(asyncio.as_completed(fs, timeout=timeout, **kwargs),
79 res = [await f for f in cls.as_completed(ifs, loop=loop, timeout=timeout,
|
| /dports/misc/py-tqdm/tqdm-4.62.3/tqdm/ |
| H A D | asyncio.py | 58 def as_completed(cls, fs, *, loop=None, timeout=None, total=None, **tqdm_kwargs): member in tqdm_asyncio
67 yield from cls(asyncio.as_completed(fs, timeout=timeout, **kwargs),
79 res = [await f for f in cls.as_completed(ifs, loop=loop, timeout=timeout,
|
| /dports/net/py-mpi4py/mpi4py-3.1.3/src/mpi4py/futures/ |
| H A D | _core.py | 19 as_completed,
49 as_completed,
|
| H A D | __init__.pyi | 8 as_completed as as_completed,
|
| H A D | _core.pyi | 11 as_completed as as_completed,
|
| /dports/devel/pytype/pytype-2021.9.9/pytype/typeshed/stubs/futures/@python2/concurrent/futures/ |
| H A D | __init__.pyi | 9 as_completed as as_completed,
|
| /dports/devel/py-types-futures/types-futures-3.3.1/concurrent-python2-stubs/futures/ |
| H A D | __init__.pyi | 9 as_completed as as_completed,
|
| /dports/devel/py-aioitertools/aioitertools-0.8.0/aioitertools/tests/ |
| H A D | asyncio.py | 29 results = await ait.list(aio.as_completed(futures))
34 async for value in aio.as_completed(futures):
44 await ait.list(aio.as_completed(futures, timeout=0.5))
49 async for _ in aio.as_completed(futures, timeout=0.5):
|
| /dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/typeshed/stdlib/3/concurrent/futures/ |
| H A D | __init__.pyi | 11 as_completed as as_completed,
|
| /dports/devel/pycharm-pro/pycharm-2020.2.3/plugins/python/helpers/typeshed/third_party/2/concurrent/futures/ |
| H A D | __init__.pyi | 11 as_completed as as_completed,
|
| /dports/devel/nuitka/Nuitka-0.6.17/nuitka/utils/ |
| H A D | ThreadedExecutor.py | 63 as_completed,
71 for future in as_completed(workers):
|
| /dports/devel/pytype/pytype-2021.9.9/pytype/typeshed/stdlib/concurrent/futures/ |
| H A D | __init__.pyi | 11 as_completed as as_completed,
|
| /dports/devel/py-mypy/mypy-0.910/mypy/typeshed/stdlib/concurrent/futures/ |
| H A D | __init__.pyi | 11 as_completed as as_completed,
|
| /dports/misc/py-tqdm/tqdm-4.62.3/tests/ |
| H A D | py37_asyncio.py | 12 as_completed = partial(tqdm_asyncio.as_completed, miniters=0, mininterval=0) variable
106 for i in as_completed([asyncio.sleep(0.01 * i) for i in range(30, 0, -1)]):
|
| /dports/multimedia/py-metadata-cleaner/metadata-cleaner-b8cd4f28c82d5da9b93cd892355b66f8b7340129/metadatacleaner/ |
| H A D | filesmanager.py | 10 from concurrent.futures import ThreadPoolExecutor, as_completed
122 for i, future in enumerate(as_completed(futures)):
176 for i, future in enumerate(as_completed(futures)):
192 for i, future in enumerate(as_completed(futures)):
|
| /dports/lang/spidermonkey60/firefox-60.9.0/third_party/python/futures/ |
| H A D | crawl.py | 13 from concurrent.futures import (as_completed, ThreadPoolExecutor,
47 for future in as_completed(future_to_url):
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/python/futures/ |
| H A D | crawl.py | 13 from concurrent.futures import (as_completed, ThreadPoolExecutor,
47 for future in as_completed(future_to_url):
|
| /dports/lang/spidermonkey78/firefox-78.9.0/third_party/python/futures/ |
| H A D | crawl.py | 13 from concurrent.futures import (as_completed, ThreadPoolExecutor,
47 for future in as_completed(future_to_url):
|
| /dports/net/py-mpi4py/mpi4py-3.1.3/demo/futures/ |
| H A D | perf_crawl.py | 23 from mpi4py.futures import MPIPoolExecutor, as_completed
58 for future in as_completed(future_to_url):
|
| /dports/net-p2p/bitcoin/bitcoin-22.0/test/fuzz/ |
| H A D | test_runner.py | 8 from concurrent.futures import ThreadPoolExecutor, as_completed
217 for future in as_completed(futures):
250 for future in as_completed(jobs):
280 for future in as_completed(jobs):
|
| /dports/net-p2p/bitcoin-utils/bitcoin-22.0/test/fuzz/ |
| H A D | test_runner.py | 8 from concurrent.futures import ThreadPoolExecutor, as_completed
217 for future in as_completed(futures):
250 for future in as_completed(jobs):
280 for future in as_completed(jobs):
|
| /dports/net-p2p/bitcoin-daemon/bitcoin-22.0/test/fuzz/ |
| H A D | test_runner.py | 8 from concurrent.futures import ThreadPoolExecutor, as_completed
217 for future in as_completed(futures):
250 for future in as_completed(jobs):
280 for future in as_completed(jobs):
|
| /dports/net-p2p/namecoin-daemon/namecoin-core-nc0.21.0.1/test/fuzz/ |
| H A D | test_runner.py | 8 from concurrent.futures import ThreadPoolExecutor, as_completed
199 for future in as_completed(futures):
224 for future in as_completed(jobs):
249 for future in as_completed(jobs):
|