preen

Author: bdraco

onvif/client.py

@@ -248,24 +248,22 @@ def __init__(
         self.dt_diff = dt_diff
         self.binding_name = binding_name
         # Create soap client
-        timeout_seconds = _DEFAULT_TIMEOUT
-        operation_timeout = read_timeout or _READ_TIMEOUT
         connector = TCPConnector(
             ssl=_NO_VERIFY_SSL_CONTEXT,
             keepalive_timeout=KEEPALIVE_EXPIRY,
         )
         session = ClientSession(
             connector=connector,
             timeout=aiohttp.ClientTimeout(
-                total=timeout_seconds,
+                total=_DEFAULT_TIMEOUT,
                 connect=_CONNECT_TIMEOUT,
-                sock_read=operation_timeout,
+                sock_read=read_timeout or _READ_TIMEOUT,
             ),
         )
         self.transport = AsyncTransportProtocolErrorHandler(
             session=session,
-            timeout=timeout_seconds,
-            operation_timeout=operation_timeout,
+            timeout=_DEFAULT_TIMEOUT,
+            operation_timeout=read_timeout or _READ_TIMEOUT,
             verify_ssl=False,
         )
         if not no_cache:

onvif/zeep_aiohttp.py

@@ -57,6 +57,12 @@ def __init__(
         self.proxy = proxy
         self._close_session = session is None
 
+        # Pre-create timeout object to avoid recreating it on each request
+        effective_timeout = self.operation_timeout or self.timeout
+        self._client_timeout = (
+            ClientTimeout(total=effective_timeout) if effective_timeout else None
+        )
+
     async def __aenter__(self) -> AIOHTTPTransport:
         """Enter async context."""
         if self.session is None: