Allow for httpx API changes

tests/test_unix_socket.py

@@ -5,6 +5,8 @@
 import subprocess
 import sys
 
+from string import ascii_lowercase
+
 import httpcore
 import httpx
 import pytest
@@ -13,6 +15,9 @@
 from sanic.response import text
 
 
+httpx_version = tuple(
+    map(int, httpx.__version__.strip(ascii_lowercase).split("."))
+)
 pytestmark = pytest.mark.skipif(os.name != "posix", reason="UNIX only")
 SOCKPATH = "/tmp/sanictest.sock"
 SOCKPATH2 = "/tmp/sanictest2.sock"
@@ -141,7 +146,10 @@ def handler(request):
 
     @app.listener("after_server_start")
     async def client(app, loop):
-        transport = httpcore.AsyncConnectionPool(uds=SOCKPATH)
+        if httpx_version >= (0, 20):
+            transport = httpx.AsyncHTTPTransport(uds=SOCKPATH)
+        else:
+            transport = httpcore.AsyncConnectionPool(uds=SOCKPATH)
         try:
             async with httpx.AsyncClient(transport=transport) as client:
                 r = await client.get("http://myhost.invalid/")
@@ -186,7 +194,10 @@ async def test_zero_downtime():
     from time import monotonic as current_time
 
     async def client():
-        transport = httpcore.AsyncConnectionPool(uds=SOCKPATH)
+        if httpx_version >= (0, 20):
+            transport = httpx.AsyncHTTPTransport(uds=SOCKPATH)
+        else:
+            transport = httpcore.AsyncConnectionPool(uds=SOCKPATH)
         for _ in range(40):
             async with httpx.AsyncClient(transport=transport) as client:
                 r = await client.get("http://localhost/sleep/0.1")