
    ^f_                    r    d dl mZ d dlmZ d dlmZ d dlmZmZm	Z	 d dl
mZ erd dlmZ dZdddZdddZdS )    )annotations)TYPE_CHECKING)get_event_loop)HeadersRequestResponse)Hub
CurlClient)Clientr   r   r   Nhub
Hub | Nonekwargsintreturnr   c                     ddl m}  || fi |S )zCreate new HTTP client.   r
   )curlr   )r   r   r   s      R/var/www/html/env/lib/python3.11/site-packages/kombu/asynchronous/http/__init__.pyr   r      s,          :c$$V$$$    c                ~    | pt                      } 	 | j        S # t          $ r t          | fi |x}| _        |cY S w xY w)z:Get or create HTTP client bound to the current event loop.)r   _current_http_clientAttributeErrorr   )r   r   clients      r   
get_clientr      sa    

!!!C''   ,23,A,A&,A,AA)s     <<)N)r   r   r   r   r   r   )
__future__r   typingr   kombu.asynchronousr   kombu.asynchronous.http.baser   r   r   kombu.asynchronous.hubr	   kombu.asynchronous.http.curlr   __all__r   r    r   r   <module>r$      s    " " " " " "             - - - - - - C C C C C C C C C C & & & & & & 8777777
6% % % % %      r   