implement thread-local connection handling for shared instances

Author: Deadpool2000

openapi_python_sdk/client.py

@@ -1,4 +1,5 @@
 import json
+import threading
 from typing import Any, Dict
 
 import httpx
@@ -15,13 +16,33 @@ class Client:
     """
 
     def __init__(self, token: str, client: Any = None, timeout: float = 30.0):
-        self.client = client if client is not None else httpx.Client(timeout=timeout)
+        self._client = client
+        self._thread_local = threading.local()
+        self.timeout = timeout
         self.auth_header: str = f"Bearer {token}"
         self.headers: Dict[str, str] = {
             "Authorization": self.auth_header,
             "Content-Type": "application/json",
         }
 
+    @property
+    def client(self) -> Any:
+        """
+        Thread-safe access to the underlying HTTP client.
+        If a custom client was provided at initialization, it is returned.
+        Otherwise, a thread-local httpx.Client is created and returned.
+        """
+        if self._client is not None:
+            return self._client
+        
+        if not hasattr(self._thread_local, "client"):
+            self._thread_local.client = httpx.Client(timeout=self.timeout)
+        return self._thread_local.client
+
+    @client.setter
+    def client(self, value: Any):
+        self._client = value
+
     def __enter__(self):
         """Enable use as a synchronous context manager."""
         return self