o
    ¨D®f_  ã                   @  st   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d„Zd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                 K  s   ddl m} || fi |¤ŽS )zCreate new HTTP client.é   r	   )Úcurlr
   )r   r   r
   © r   úY/home/ubuntu/webapp/venv/lib/python3.10/site-packages/kombu/asynchronous/http/__init__.pyr      s   r   c                 K  s@   | pt ƒ } z| jW S  ty   t| fi |¤Ž }| _| Y S w )z:Get or create HTTP client bound to the current event loop.)r   Ú_current_http_clientÚAttributeErrorr   )r   r   Úclientr   r   r   Ú
get_client   s   
þr   )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   r   r   Ú<module>   s    