Searched refs:as_completed (Results 1 – 20 of 20) sorted by relevance
| /third_party/python/Lib/concurrent/futures/ |
| D | __init__.py | 18 as_completed)
|
| D | _base.py | 201 def as_completed(fs, timeout=None): function
|
| /third_party/python/Misc/NEWS.d/ |
| D | 3.6.3.rst | 7 Re-allow arbitrary iterables in `concurrent.futures.as_completed()`. Fixes
|
| D | 3.6.3rc1.rst | 398 The ``map()`` and ``as_completed()`` iterators in ``concurrent.futures`` now
|
| D | 3.10.0b1.rst | 1221 :func:`~asyncio.as_completed` and constructors of :class:`~asyncio.Future`,
|
| D | 3.7.0a1.rst | 1756 The ``map()`` and ``as_completed()`` iterators in ``concurrent.futures`` now
|
| D | 3.8.0a1.rst | 2992 :func:`as_completed`, in order to prevent timeouts from deviating when the
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 720 completed = set(futures.as_completed(
736 for future in futures.as_completed(
757 f for f in futures.as_completed(itertools.repeat(future1, 3))
769 for future in futures.as_completed(futures_list, timeout=0):
777 for future in futures.as_completed(futures_list):
791 list(futures.as_completed(futures_list, timeout=0))
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 208 for future in concurrent.futures.as_completed(future_to_url):
396 :func:`as_completed` or :func:`wait`) will be woken up.
470 .. function:: as_completed(fs, timeout=None)
476 :func:`as_completed` is called will be yielded first. The returned iterator
479 original call to :func:`as_completed`. *timeout* can be an int or float. If
|
| D | asyncio-api-index.rst | 57 * - ``for in`` :func:`as_completed`
|
| D | asyncio-future.rst | 275 :func:`concurrent.futures.as_completed` functions.
|
| D | asyncio-task.rst | 654 .. function:: as_completed(aws, *, timeout=None)
672 for coro in as_completed(aws):
|
| /third_party/cef/tools/yapf/yapf/ |
| D | __init__.py | 231 for future in concurrent.futures.as_completed(future_formats):
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_tasks.py | 1585 for f in asyncio.as_completed([b, c, a]):
1614 for f in asyncio.as_completed([a, b], timeout=0.12):
1647 for f in asyncio.as_completed([a], timeout=1):
1667 futs = list(asyncio.as_completed(fs))
1694 futs = list(asyncio.as_completed(fs))
1718 for f in asyncio.as_completed([c, c, coro('spam')]):
1735 futs = asyncio.as_completed([a])
1748 futs = list(asyncio.as_completed([coro()]))
1762 futs = asyncio.as_completed([coro()])
2269 asyncio.as_completed(fut))
[all …]
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/ |
| D | _rpc_part_2_test.py | 270 futures.as_completed(response_futures),
|
| D | _rpc_test.py | 486 futures.as_completed(response_futures),
|
| /third_party/python/Lib/asyncio/ |
| D | tasks.py | 524 def as_completed(fs, *, timeout=None): function
|
| /third_party/python/Doc/whatsnew/ |
| D | 3.8.rst | 1683 :func:`asyncio.wait_for`, :func:`asyncio.wait`, :func:`asyncio.as_completed`,
|
| D | 3.10.rst | 1697 :func:`~asyncio.shield`, :func:`~asyncio.as_completed` and constructors of
|
| /third_party/python/Misc/ |
| D | HISTORY | 2277 - Issue #20566: Change asyncio.as_completed() to use a Queue, to
2287 TimerHandle; as_completed() and wait() raise TypeError if the passed
2465 in gather(), wait(), as_completed(); use a bytearray for buffering
2494 - Issue #20367: Fix behavior of concurrent.futures.as_completed() for
|