Lines Matching refs:waiter
148 for waiter in self._drain_waiters:
149 if not waiter.done():
150 waiter.set_result(None)
158 for waiter in self._drain_waiters:
159 if not waiter.done():
161 waiter.set_result(None)
163 waiter.set_exception(exc)
170 waiter = self._loop.create_future()
171 self._drain_waiters.append(waiter)
173 await waiter
175 self._drain_waiters.remove(waiter)
430 info.append(f'waiter={self._waiter!r}')
445 waiter = self._waiter
446 if waiter is not None:
448 if not waiter.cancelled():
449 waiter.set_exception(exc)
453 waiter = self._waiter
454 if waiter is not None:
456 if not waiter.cancelled():
457 waiter.set_result(None)
677 # This used to just loop creating a new waiter hoping to