More coverage improvements (#711)

* More coverage improvements

* Drop redundant 'sleep' usage in test utils

diff --git a/httpx/backends/auto.py b/httpx/backends/auto.py
index cb03798177ce86b34188368a226b9c46ab7c33cf..0c0d2d88acf6cd4fe3247853a8da7412124e827d 100644 (file)
--- a/httpx/backends/auto.py
+++ b/httpx/backends/auto.py
@@ -18,7 +18,7 @@ class AutoBackend(ConcurrencyBackend):
     def backend(self) -> ConcurrencyBackend:
         if not hasattr(self, "_backend_implementation"):
             backend = sniffio.current_async_library()
-            if backend not in ("asyncio", "trio"):
+            if backend not in ("asyncio", "trio"):  # pragma: nocover
                 raise RuntimeError(f"Unsupported concurrency backend {backend!r}")
             self._backend_implementation = lookup_backend(backend)
         return self._backend_implementation

diff --git a/httpx/utils.py b/httpx/utils.py
index 2a6aa3f99ab883ad9313c23b2f84dd61419dfa6b..dfa9af8aaf1c69a7428ba4fa20c0225bc5231bfc 100644 (file)
--- a/httpx/utils.py
+++ b/httpx/utils.py
@@ -253,15 +253,6 @@ def get_logger(name: str) -> Logger:
     return typing.cast(Logger, logger)
 
 
-def kv_format(**kwargs: typing.Any) -> str:
-    """Format arguments into a key=value line.
-
-    >>> formatkv(x=1, name="Bob")
-    "x=1 name='Bob'"
-    """
-    return " ".join(f"{key}={value!r}" for key, value in kwargs.items())
-
-
 def should_not_be_proxied(url: "URL") -> bool:
     """ Return True if url should not be proxied,
     return False otherwise.

diff --git a/tests/concurrency.py b/tests/concurrency.py
index 1d77df3939e6cffb7cfa42097209311f787cb685..361e29b1cbe3449885a63ba1e37c18c63eb76ace 100644 (file)
--- a/tests/concurrency.py
+++ b/tests/concurrency.py
@@ -14,26 +14,6 @@ from httpx.backends.auto import AutoBackend
 from httpx.backends.trio import TrioBackend
 
 
-@functools.singledispatch
-async def sleep(backend, seconds: int):
-    raise NotImplementedError  # pragma: no cover
-
-
-@sleep.register(AutoBackend)
-async def _sleep_auto(backend, seconds: int):
-    return await sleep(backend.backend, seconds=seconds)
-
-
-@sleep.register(AsyncioBackend)
-async def _sleep_asyncio(backend, seconds: int):
-    await asyncio.sleep(seconds)
-
-
-@sleep.register(TrioBackend)
-async def _sleep_trio(backend, seconds: int):
-    await trio.sleep(seconds)
-
-
 @functools.singledispatch
 async def run_concurrently(backend, *coroutines: typing.Callable[[], typing.Awaitable]):
     raise NotImplementedError  # pragma: no cover

diff --git a/tests/dispatch/utils.py b/tests/dispatch/utils.py
index fa4d9ab5d2f7fe587645a19f6fbb2da90cc6f79e..5f92cd82d36700ca11c625d9263746b11011cac9 100644 (file)
--- a/tests/dispatch/utils.py
+++ b/tests/dispatch/utils.py
@@ -7,7 +7,6 @@ import h2.events
 
 from httpx import Request, Timeout
 from httpx.backends.base import BaseSocketStream, lookup_backend
-from tests.concurrency import sleep
 
 
 class MockHTTP2Backend:
@@ -49,7 +48,6 @@ class MockHTTP2Server(BaseSocketStream):
         return "HTTP/2"
 
     async def read(self, n, timeout, flag=None) -> bytes:
-        await sleep(self.backend, 0)
         send, self.buffer = self.buffer[:n], self.buffer[n:]
         return send
 
@@ -195,7 +193,6 @@ class MockRawSocketStream(BaseSocketStream):
         self.backend.received_data.append(data)
 
     async def read(self, n, timeout, flag=None) -> bytes:
-        await sleep(self.backend.backend, 0)
         if not self.backend.data_to_send:
             return b""
         return self.backend.data_to_send.pop(0)

diff --git a/tests/test_decoders.py b/tests/test_decoders.py
index f0b8b01db166742cfe08b4981690bed9b9324dd7..f320d9412e0884c86f06e18eee421c28bfe490bc 100644 (file)
--- a/tests/test_decoders.py
+++ b/tests/test_decoders.py
@@ -125,10 +125,7 @@ def test_decoding_errors(header_value):
     body = b"test 123"
     compressed_body = brotli.compress(body)[3:]
     with pytest.raises(httpx.DecodingError):
-        response = httpx.Response(
-            200, headers=headers, content=compressed_body, request=REQUEST
-        )
-        response.content
+        httpx.Response(200, headers=headers, content=compressed_body, request=REQUEST)
 
 
 @pytest.mark.parametrize(