Lines Matching refs:timeout
389 async def wait(fs, *, timeout=None, return_when=ALL_COMPLETED):
403 when the timeout occurs are returned in the second set.
418 return await _wait(fs, timeout, return_when, loop)
426 async def wait_for(fut, timeout):
427 """Wait for the single Future or coroutine to complete, with timeout.
431 Returns result of the Future or coroutine. When a timeout occurs,
441 if timeout is None:
444 if timeout <= 0:
457 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
464 # wait until the future completes or the timeout
497 async def _wait(fs, timeout, return_when, loop):
505 if timeout is not None:
506 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
558 def as_completed(fs, *, timeout=None):
571 If a timeout is specified, the 'await' will raise
572 TimeoutError when the timeout occurs before all Futures are done.
609 if todo and timeout is not None:
610 timeout_handle = loop.call_later(timeout, _on_timeout)