Lines Matching refs:loop

39 -                        with CeilTimeout(real_timeout.connect, loop=self._loop):
52 -                    with async_timeout.timeout(self._timeout, loop=self._loop):
62 -                        timeout or self._receive_timeout, loop=self._loop
126 -            self._task = current_task(loop=self._loop)
142 +        loop = get_running_loop()
143 +        now = loop.time()
168 -            with CeilTimeout(timeout, loop=self._loop):
177 -                                with CeilTimeout(end_t - now, loop=loop):
181                                  now = loop.time()
190 -                with async_timeout.timeout(self._timeout, loop=self._loop):
197                  self._waiting = loop.create_future()
200 -                        timeout or self._receive_timeout, loop=self._loop
244 @@ -391,48 +390,22 @@ async def test_weakref_handle_weak(loop) -> None:
250 -    loop = mock.Mock()
251 -    loop.time.return_value = 10.1
252 -    helpers.call_later(cb, 10.1, loop)
253 -    loop.call_at.assert_called_with(21.0, cb)
258 -    loop = mock.Mock()
259 -    helpers.call_later(cb, 0, loop)
260 -    assert not loop.call_at.called
263 -async def test_ceil_timeout(loop) -> None:
264 -    with helpers.CeilTimeout(None, loop=loop) as timeout:
272 -def test_ceil_timeout_no_task(loop) -> None:
274 -        with helpers.CeilTimeout(10, loop=loop):
281 -async def test_ceil_timeout_round(loop) -> None:
282 -    with helpers.CeilTimeout(7.5, loop=loop) as cm:
294 -async def test_ceil_timeout_small(loop) -> None:
295 -    with helpers.CeilTimeout(1.1, loop=loop) as cm: