Lines Matching refs:future
337 def __wakeup(self, future):
339 future.result()
344 # Don't pass the value of `future.result()` explicitly,
464 # wait until the future completes or the timeout
542 """Cancel the *fut* future or task and wait until it completes."""
634 future = loop.create_future()
637 future, result)
639 return await future
645 """Wrap a coroutine or an awaitable in a future.
655 raise ValueError('The future belongs to a different loop than '
719 """Return a future aggregating results from the given coroutines/futures.
721 Coroutines will be wrapped in a future and scheduled in the event
726 done successfully, the returned future's result is the list of
732 future.
780 # and set it to the 'outer' future.
842 """Wait for a future, shielding it from cancellation.
914 future = concurrent.futures.Future()
918 futures._chain_future(ensure_future(coro, loop=loop), future)
922 if future.set_running_or_notify_cancel():
923 future.set_exception(exc)
927 return future