Searched refs:return_when (Results 1 – 10 of 10) sorted by relevance
| /external/python/cpython3/Lib/concurrent/futures/ |
| D | _base.py | 152 def _create_and_install_waiters(fs, return_when): argument
153 if return_when == _AS_COMPLETED:
155 elif return_when == FIRST_COMPLETED:
161 if return_when == FIRST_EXCEPTION:
163 elif return_when == ALL_COMPLETED:
166 raise ValueError("Invalid return condition: %r" % return_when)
260 def wait(fs, timeout=None, return_when=ALL_COMPLETED): argument
289 if (return_when == FIRST_COMPLETED) and done:
291 elif (return_when == FIRST_EXCEPTION) and done:
299 waiter = _create_and_install_waiters(fs, return_when)
|
| /external/python/futures/concurrent/futures/ |
| D | _base.py | 154 def _create_and_install_waiters(fs, return_when): argument
155 if return_when == _AS_COMPLETED:
157 elif return_when == FIRST_COMPLETED:
163 if return_when == FIRST_EXCEPTION:
165 elif return_when == ALL_COMPLETED:
168 raise ValueError("Invalid return condition: %r" % return_when)
266 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)
|
| /external/python/cpython3/Lib/asyncio/ |
| D | tasks.py | 335 async def wait(fs, *, loop=None, timeout=None, return_when=ALL_COMPLETED): argument
355 if return_when not in (FIRST_COMPLETED, FIRST_EXCEPTION, ALL_COMPLETED):
363 return await _wait(fs, timeout, return_when, loop)
428 async def _wait(fs, timeout, return_when, loop): argument
444 return_when == FIRST_COMPLETED or
445 return_when == FIRST_EXCEPTION and (not f.cancelled() and
|
| /external/python/futures/ |
| D | test_futures.py | 304 return_when=futures.FIRST_COMPLETED)
314 return_when=futures.FIRST_COMPLETED)
328 return_when=futures.FIRST_EXCEPTION)
342 return_when=futures.FIRST_EXCEPTION)
354 return_when=futures.FIRST_EXCEPTION)
369 return_when=futures.ALL_COMPLETED)
388 return_when=futures.ALL_COMPLETED)
410 futures.wait(fs, return_when=futures.ALL_COMPLETED)
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 451 return_when=futures.FIRST_COMPLETED)
461 return_when=futures.FIRST_COMPLETED)
475 return_when=futures.FIRST_EXCEPTION)
489 return_when=futures.FIRST_EXCEPTION)
501 return_when=futures.FIRST_EXCEPTION)
516 return_when=futures.ALL_COMPLETED)
535 return_when=futures.ALL_COMPLETED)
557 futures.wait(fs, return_when=futures.ALL_COMPLETED)
|
| /external/python/futures/docs/ |
| D | index.rst | 305 .. function:: wait(fs, timeout=None, return_when=ALL_COMPLETED)
317 *return_when* indicates when this function should return. It must be one of
|
| /external/python/cpython3/Doc/library/ |
| D | asyncio-task.rst | 469 return_when=ALL_COMPLETED)
473 by *return_when*.
496 *return_when* indicates when this function should return. It must
|
| D | concurrent.futures.rst | 395 .. function:: wait(fs, timeout=None, return_when=ALL_COMPLETED)
407 *return_when* indicates when this function should return. It must be one of
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 962 wait_coro = asyncio.wait([sleep_coro], return_when=-1, loop=self.loop)
983 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED,
1015 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED,
1044 asyncio.wait([b, a], return_when=asyncio.FIRST_EXCEPTION,
1075 task = asyncio.wait([b, a], return_when=asyncio.FIRST_EXCEPTION,
|
| /external/python/cpython3/Misc/ |
| D | HISTORY | 8022 return_when=ALL_COMPLETED)``. Patch by Matt Joiner.
|