o
    pkjB                     @   s   d Z ddl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dfddZ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)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   [/home/djax/ivt_ai_plugin/venv/lib/python3.10/site-packages/google/genai/_gaos/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   C   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#   Q   r$   zAsyncHttpClient.build_requestc                    r@   r   r   r%   r   r   r   aclosed   s   zAsyncHttpClient.acloser'   )r(   r)   r*   r+   r,   r-   r.   r   r/   r0   r1   r2   r3   r   r4   r5   r   r6   r7   r8   r   r9   r:   r;   r<   r=   r#   rA   r   r   r   r   r?   A   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   rB   h   s   
 rB   ownersync_clientsync_client_suppliedr   c                 C   s>   d| _ |dur|sz|  W dS  ty   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.
    N)rC   r&   	Exception)rF   rG   rH   r   r   r   close_clientsm   s   rK   rD   async_client_suppliedc                 C   sv   d| _ |dur7|s9zt }t| | W dS  ty6   zt|  W Y dS  ty5   Y Y dS w w dS dS rI   )rD   asyncioget_running_looprun_coroutine_threadsaferA   RuntimeErrorrun)rF   rD   rL   loopr   r   r   close_clients_async   s   rS   )__doc__rM   typing_extensionsr   r   r+   typingr   r   r   r   r?   rB   r.   rK   rS   r   r   r   r   <module>   s8   &&


