Lines Matching refs:waiter
421 def _release_waiter(waiter, *args):
422 if not waiter.done():
423 waiter.set_result(None)
456 waiter = loop.create_future()
457 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
458 cb = functools.partial(_release_waiter, waiter)
466 await waiter
503 waiter = loop.create_future()
506 timeout_handle = loop.call_later(timeout, _release_waiter, waiter)
518 if not waiter.done():
519 waiter.set_result(None)
525 await waiter
544 waiter = loop.create_future()
545 cb = functools.partial(_release_waiter, waiter)
552 await waiter