Searched refs:return_when (Results 1 – 10 of 10) sorted by relevance
| /external/python/cpython3/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
294 if (return_when == FIRST_COMPLETED) and done:
296 elif (return_when == FIRST_EXCEPTION) and done:
304 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/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/asyncio/ |
| D | tasks.py | 373 async def wait(fs, *, loop=None, timeout=None, return_when=ALL_COMPLETED): argument
393 if return_when not in (FIRST_COMPLETED, FIRST_EXCEPTION, ALL_COMPLETED):
413 return await _wait(fs, timeout, return_when, loop)
498 async def _wait(fs, timeout, return_when, loop): argument
514 return_when == FIRST_COMPLETED or
515 return_when == FIRST_EXCEPTION and (not f.cancelled() and
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 571 return_when=futures.FIRST_COMPLETED)
581 return_when=futures.FIRST_COMPLETED)
595 return_when=futures.FIRST_EXCEPTION)
609 return_when=futures.FIRST_EXCEPTION)
621 return_when=futures.FIRST_EXCEPTION)
636 return_when=futures.ALL_COMPLETED)
655 return_when=futures.ALL_COMPLETED)
677 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 | concurrent.futures.rst | 435 .. function:: wait(fs, timeout=None, return_when=ALL_COMPLETED)
448 *return_when* indicates when this function should return. It must be one of
|
| D | asyncio-task.rst | 504 return_when=ALL_COMPLETED)
508 by *return_when*.
525 *return_when* indicates when this function should return. It must
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 1346 wait_coro = asyncio.wait([sleep_coro], return_when=-1)
1367 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED))
1396 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED))
1423 asyncio.wait([b, a], return_when=asyncio.FIRST_EXCEPTION))
1453 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.
|