U
    Íø.e_  ã                   @  s„   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rTd dlmZ dZdd	d
ddœdd„Zdd	d
ddœdd„ZdS )é    )Úannotations)ÚTYPE_CHECKING)Úget_event_loop)ÚHeadersÚRequestÚResponse)ÚHub©Ú
CurlClient)ÚClientr   r   r   Nz
Hub | NoneÚintr
   )ÚhubÚkwargsÚreturnc                 K  s   ddl m} || f|ŽS )zCreate new HTTP client.é   r	   )Zcurlr
   )r   r   r
   © r   úD/tmp/pip-unpacked-wheel-48hrr5dg/kombu/asynchronous/http/__init__.pyr      s    r   c                 K  sB   | pt ƒ } z| jW S  tk
r<   t| f|Ž }| _| Y S X dS )z:Get or create HTTP client bound to the current event loop.N)r   Z_current_http_clientÚAttributeErrorr   )r   r   Úclientr   r   r   Ú
get_client   s    
r   )N)N)Ú
__future__r   Útypingr   Zkombu.asynchronousr   Zkombu.asynchronous.http.baser   r   r   Zkombu.asynchronous.hubr   Zkombu.asynchronous.http.curlr
   Ú__all__r   r   r   r   r   r   Ú<module>   s   