Lines Matching refs:_loop
39 - with CeilTimeout(real_timeout.connect, loop=self._loop):
52 - with async_timeout.timeout(self._timeout, loop=self._loop):
59 self._waiting = self._loop.create_future()
62 - timeout or self._receive_timeout, loop=self._loop
94 return await self._loop.create_connection(*args, **kwargs) # type: ignore # noqa
103 _, proto = await self._loop.create_unix_connection(
112 _, proto = await self._loop.create_pipe_connection( # type: ignore
126 - self._task = current_task(loop=self._loop)
131 - now = self._loop.time()
136 - self._cancel_handler = self._loop.call_at(when, self._cancel_task)
168 - with CeilTimeout(timeout, loop=self._loop):
190 - with async_timeout.timeout(self._timeout, loop=self._loop):
200 - timeout or self._receive_timeout, loop=self._loop