Lines Matching +full:bare +full:- +full:fs
31 # is not thread safe. See bpo-11866 for a longer explanation.
71 "the method support will be mandatory for third-party "
85 # - Either _fut_waiter is None, and _step() is scheduled;
86 # - or _fut_waiter is some Future, and _step() is *not* scheduled.
99 del self._source_traceback[-1]
107 self._name = f'Task-{_task_name_counter()}'
215 # https://github.com/python/cpython/pull/31394#issuecomment-1053545331
247 self._num_cancels_requested -= 1
319 # Bare yield relinquishes control for one event loop iteration.
349 # that return non-generator iterators from their `__iter__`.
389 async def wait(fs, *, timeout=None, return_when=ALL_COMPLETED): argument
390 """Wait for the Futures or Tasks given by fs to complete.
392 The fs iterable must not be empty.
400 done, pending = await asyncio.wait(fs)
405 if futures.isfuture(fs) or coroutines.iscoroutine(fs):
406 raise TypeError(f"expect a list of futures, not {type(fs).__name__}")
407 if not fs:
412 fs = set(fs)
414 if any(coroutines.iscoroutine(f) for f in fs):
418 return await _wait(fs, timeout, return_when, loop)
487 # exception, we should re-raise it
497 async def _wait(fs, timeout, return_when, loop): argument
500 The fs argument must be a collection of Futures.
502 assert fs, 'Set of Futures is empty.'
507 counter = len(fs)
511 counter -= 1
521 for f in fs:
529 for f in fs:
533 for f in fs:
558 def as_completed(fs, *, timeout=None): argument
567 for f in as_completed(fs):
574 Note: The futures 'f' are not necessarily members of fs.
576 if futures.isfuture(fs) or coroutines.iscoroutine(fs):
577 raise TypeError(f"expect an iterable of futures, not {type(fs).__name__}")
583 todo = {ensure_future(f, loop=loop) for f in set(fs)}
620 when the 'delay' is set to 0. It uses a bare 'yield'
736 cancelled, this is treated as if it raised CancelledError --
814 outer = None # bpo-46672
856 still cancelled, so the yield-from expression still raises
870 a task disappearing mid-execution. The event loop only keeps