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)
233 def wait(fs, timeout=None, return_when=ALL_COMPLETED): argument
262 if (return_when == FIRST_COMPLETED) and done:
264 elif (return_when == FIRST_EXCEPTION) and done:
272 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 | 279 def wait(fs, *, loop=None, timeout=None, return_when=ALL_COMPLETED): argument
299 if return_when not in (FIRST_COMPLETED, FIRST_EXCEPTION, ALL_COMPLETED):
300 raise ValueError('Invalid return_when value: {}'.format(return_when))
307 return (yield from _wait(fs, timeout, return_when, loop))
362 def _wait(fs, timeout, return_when, loop): argument
378 return_when == FIRST_COMPLETED or
379 return_when == FIRST_EXCEPTION and (not f.cancelled() and
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 226 return_when=futures.FIRST_COMPLETED)
236 return_when=futures.FIRST_COMPLETED)
250 return_when=futures.FIRST_EXCEPTION)
264 return_when=futures.FIRST_EXCEPTION)
276 return_when=futures.FIRST_EXCEPTION)
291 return_when=futures.ALL_COMPLETED)
310 return_when=futures.ALL_COMPLETED)
332 futures.wait(fs, return_when=futures.ALL_COMPLETED)
|
| /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/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 | 362 .. function:: wait(fs, timeout=None, return_when=ALL_COMPLETED)
374 *return_when* indicates when this function should return. It must be one of
|
| D | asyncio-task.rst | 653 return_when=ALL_COMPLETED)
665 *return_when* indicates when this function should return. It must be one of
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_tasks.py | 799 wait_coro = asyncio.wait([sleep_coro], return_when=-1, loop=self.loop)
820 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED,
852 asyncio.wait([b, a], return_when=asyncio.FIRST_COMPLETED,
881 asyncio.wait([b, a], return_when=asyncio.FIRST_EXCEPTION,
913 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.
|