o
    i                     @   s   d Z ddlZddlmZ ddlmZmZ ddlZddlm	Z	m
Z
mZ eG dd deZeG dd	 d	eZG d
d deZdedeedf dedeedf deddfddZdS )zACode generated by Speakeasy (https://speakeasy.com). DO NOT EDIT.    N)ThreadPoolExecutor)Protocolruntime_checkable)AnyOptionalUnionc                   @     e Zd Zdejejddejdedeejj	ej
jdf deeej
jf dejf
d	d
Zdddddddejdd	dedejjdeejj deejj deejj dee deejj deejj deejj deejjej
jf deejj dejfddZdddZdS )
HttpClientFstreamauthfollow_redirectsrequestr   r   Nr   returnc                C      d S N selfr   r   r   r   r   r   ^/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/mistralai_gcp/httpclient.pysend   s   zHttpClient.send	contentdatafilesjsonparamsheaderscookiestimeout
extensionsmethodurlr   r   r   r   r   r   r   r   r    c       	         C   r   r   r   r   r!   r"   r   r   r   r   r   r   r   r   r    r   r   r   build_request      zHttpClient.build_requestc                 C   r   r   r   r   r   r   r   close.   s   zHttpClient.closer   N)__name__
__module____qualname__httpxUSE_CLIENT_DEFAULTRequestboolr   _types	AuthTypes_clientUseClientDefaultResponser   strURLTypesr   RequestContentRequestDataRequestFilesr   QueryParamTypesHeaderTypesCookieTypesTimeoutTypesRequestExtensionsr$   r'   r   r   r   r   r	      p    





	




r	   c                   @   r   )AsyncHttpClientFr
   r   r   r   Nr   r   c                      d S r   r   r   r   r   r   r   4   s   zAsyncHttpClient.sendr   r!   r"   r   r   r   r   r   r   r   r   r    c       	         C   r   r   r   r#   r   r   r   r$   B   r%   zAsyncHttpClient.build_requestc                    rA   r   r   r&   r   r   r   acloseU   s   zAsyncHttpClient.acloser(   )r)   r*   r+   r,   r-   r.   r/   r   r0   r1   r2   r3   r4   r   r5   r6   r   r7   r8   r9   r   r:   r;   r<   r=   r>   r$   rB   r   r   r   r   r@   2   r?   r@   c                   @   s.   e Zd ZU eedf ed< eedf ed< dS )ClientOwnerNclientasync_client)r)   r*   r+   r   r	   __annotations__r@   r   r   r   r   rC   Y   s   
 rC   ownersync_clientsync_client_suppliedrE   async_client_suppliedr   c                 C   s   d| _ d| _|dur|sz|  W n	 ty   Y nw |durt|svd}zt  d}W n	 ty5   Y nw z3|r`tdd}|tj	|
 }|  W d   W dS 1 sXw   Y  W dS t	|
  W dS  tys   Y dS w dS dS )z
    A finalizer function that is meant to be used with weakref.finalize to close
    httpx clients used by an SDK so that underlying resources can be garbage
    collected.
    NFT   )max_workers)rD   rE   r'   	Exceptionasyncioget_running_loopRuntimeErrorr   submitrunrB   result)rG   rH   rI   rE   rJ   is_asyncexecutorfuturer   r   r   close_clients^   s6   
&rW   )__doc__rN   concurrent.futuresr   typing_extensionsr   r   r,   typingr   r   r   r	   r@   rC   r/   rW   r   r   r   r   <module>   s0    &&

