
    Ih                    X    d dl mZ d dlmZ d dlmZmZmZmZ d dl	m
Z
 dZd	d
dZd	d
dZy)    )annotations)get_event_loop)
BaseClientHeadersRequestResponse)Hub)Clientr   r   r   
get_clientNc                     ddl m}  || fi |S )zCreate new HTTP client.   )Urllib3Client)urllib3_clientr   )hubkwargsr   s      Y/var/www/html/planif/env/lib/python3.12/site-packages/kombu/asynchronous/http/__init__.pyr
   r
   
   s    -'''    c                    | xs
 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   r   r      sK    

!!C''' ,23,A&,AA)s    ==)N)r   z
Hub | Noner   intreturnr   )
__future__r   kombu.asynchronousr   kombu.asynchronous.http.baser   r   r   r   kombu.asynchronous.hubr	   __all__r
   r    r   r   <module>r       s#    " - O O &
D(r   