Searched refs:return_when (Results 1 – 10 of 10) sorted by relevance
| /third_party/python/Lib/concurrent/futures/ |
| D | _base.py | 157 def _create_and_install_waiters(fs, return_when): argument
158 if return_when == _AS_COMPLETED:
160 elif return_when == FIRST_COMPLETED:
166 if return_when == FIRST_EXCEPTION:
168 elif return_when == ALL_COMPLETED:
171 raise ValueError("Invalid return condition: %r" % return_when)
265 def wait(fs, timeout=None, return_when=ALL_COMPLETED): argument
295 if (return_when == FIRST_COMPLETED) and done:
297 elif (return_when == FIRST_EXCEPTION) and done:
305 waiter = _create_and_install_waiters(fs, return_when)
|
| /third_party/python/Lib/asyncio/ |
| D | tasks.py | 349 async def wait(fs, *, timeout=None, return_when=ALL_COMPLETED): argument
369 if return_when not in (FIRST_COMPLETED, FIRST_EXCEPTION, ALL_COMPLETED):
384 return await _wait(fs, timeout, return_when, loop)
463 async def _wait(fs, timeout, return_when, loop): argument
479 return_when == FIRST_COMPLETED or
480 return_when == FIRST_EXCEPTION and (not f.cancelled() and
|
| /third_party/python/Lib/test/ |
| D | test_concurrent_futures.py | 586 return_when=futures.ALL_COMPLETED)
597 return_when=futures.FIRST_COMPLETED)
607 return_when=futures.FIRST_COMPLETED)
621 return_when=futures.FIRST_EXCEPTION)
635 return_when=futures.FIRST_EXCEPTION)
647 return_when=futures.FIRST_EXCEPTION)
662 return_when=futures.ALL_COMPLETED)
681 return_when=futures.ALL_COMPLETED)
703 futures.wait(fs, return_when=futures.ALL_COMPLETED)
|
| /third_party/grpc/src/python/grpcio/grpc/experimental/aio/ |
| D | _interceptor.py | 517 return_when=asyncio.FIRST_COMPLETED)
543 return_when=asyncio.FIRST_COMPLETED)
|
| /third_party/grpc/src/python/grpcio/grpc/aio/ |
| D | _interceptor.py | 516 return_when=asyncio.FIRST_COMPLETED)
542 return_when=asyncio.FIRST_COMPLETED)
|
| /third_party/python/Doc/library/ |
| D | concurrent.futures.rst | 435 .. function:: wait(fs, timeout=None, return_when=ALL_COMPLETED)
449 *return_when* indicates when this function should return. It must be one of
|
| D | asyncio-task.rst | 556 .. coroutinefunction:: wait(aws, *, timeout=None, return_when=ALL_COMPLETED)
560 by *return_when*.
577 *return_when* indicates when this function should return. It must
|
| /third_party/grpc/src/python/grpcio_tests/tests_aio/unit/ |
| D | server_test.py | 499 asyncio.wait(rpcs, return_when=asyncio.FIRST_EXCEPTION))
|
| /third_party/python/Lib/test/test_asyncio/ |
| D | test_tasks.py | 1325 wait_coro = asyncio.wait([sleep_coro], return_when=-1)
1346 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED))
1375 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED))
1402 asyncio.wait([b, a], return_when=asyncio.FIRST_EXCEPTION))
1432 task = asyncio.wait([b, a], return_when=asyncio.FIRST_EXCEPTION)
|
| /third_party/python/Misc/ |
| D | HISTORY | 8022 return_when=ALL_COMPLETED)``. Patch by Matt Joiner.
|