U Ób‡hã@slddlmZddlmZddlmZmZmZmZddl m Z dZ dddd d œd d „Z dddd d œd d„Z dS)é)Ú annotations)Úget_event_loop)Ú BaseClientÚHeadersÚRequestÚResponse)ÚHub)ÚClientrrrÚ get_clientNz Hub | NoneÚintr)ÚhubÚkwargsÚreturncKsddlm}||f|ŽS)zCreate new HTTP client.é)Ú Urllib3Client)Zurllib3_clientr)r r r©rúD/tmp/pip-unpacked-wheel-earovzxb/kombu/asynchronous/http/__init__.pyr s r cKsB|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 Úclientrrrr s  r )N)N)Ú __future__rZkombu.asynchronousrZkombu.asynchronous.http.baserrrrZkombu.asynchronous.hubrÚ__all__r r rrrrÚs