Lines Matching refs:waiter
14 waiter=None, extra=None, **kwargs):
53 self._loop.create_task(self._connect_pipes(waiter))
156 async def _connect_pipes(self, waiter):
188 if waiter is not None and not waiter.cancelled():
189 waiter.set_exception(exc)
191 if waiter is not None and not waiter.cancelled():
192 waiter.set_result(None)
228 waiter = self._loop.create_future()
229 self._exit_waiters.append(waiter)
230 return await waiter
246 for waiter in self._exit_waiters:
247 if not waiter.cancelled():
248 waiter.set_result(self._returncode)