MCP enable over UNIX socket

Signed-off-by: John <[email protected]>

Author: pdxjohnny

src/mcp/client/sse.py

@@ -24,6 +24,7 @@ async def sse_client(
     headers: dict[str, Any] | None = None,
     timeout: float = 5,
     sse_read_timeout: float = 60 * 5,
+    transport: httpx.AsyncHTTPTransport | None = None,
 ):
     """
     Client transport for SSE.
@@ -43,7 +44,10 @@ async def sse_client(
     async with anyio.create_task_group() as tg:
         try:
             logger.info(f"Connecting to SSE endpoint: {remove_request_params(url)}")
-            async with httpx.AsyncClient(headers=headers) as client:
+            async with httpx.AsyncClient(
+                headers=headers,
+                transport=transport,
+            ) as client:
                 async with aconnect_sse(
                     client,
                     "GET",