U ‰dOã@s<ddlmZddlmZmZmZdZd dd„Zd dd „ZdS) é)Úget_event_loopé)ÚHeadersÚRequestÚResponse)ÚClientrrrNcKsddlm}||f|ŽS)zCreate new HTTP client.r)Ú CurlClient)Zcurlr)ÚhubÚkwargsr©r úD/tmp/pip-unpacked-wheel-hqfrjlvz/kombu/asynchronous/http/__init__.pyrs rcKsB|ptƒ}z|jWStk r<t|f|Ž}|_|YSXdS)z:Get or create HTTP client bound to the current event loop.N)rZ_current_http_clientÚAttributeErrorr)r r Úclientr r r Ú get_clients  r)N)N) Zkombu.asynchronousrÚbaserrrÚ__all__rrr r r r Ús