ó
O'—^c           @@  sY   d  Z  d d l m Z d d l Z d g Z d a d „  Z d „  Z d „  Z	 d „  Z
 d S(	   s   
kombu.syn
=========

i    (   t   absolute_importNt   detect_environmentc         O@  s   |  | | Ž  S(   N(    (   t   funt   argst   kwargs(    (    s+   /tmp/pip-unpacked-wheel-UAnTfW/kombu/syn.pyt   blocking   s    c         C@  s   d  S(   N(    (   t   type(    (    s+   /tmp/pip-unpacked-wheel-UAnTfW/kombu/syn.pyt   select_blocking_method   s    c          C@  s¶   d t  j k rV y0 d d l m }  d d  l } |  | ƒ r> d SWqV t k
 rR qV Xn  d t  j k r² y6 d d l m } d d  l } | j | j k rš d SWq² t k
 r® q² Xn  d S(   Nt   eventleti    (   t   is_monkey_patchedt   gevent(   t   sockett   default(   t   syst   modulest   eventlet.patcherR	   R   t   ImportErrorR
   (   t   is_eventletR   t   _gsocket(    (    s+   /tmp/pip-unpacked-wheel-UAnTfW/kombu/syn.pyt   _detect_environment   s"    c           C@  s   t  d  k r t ƒ  a  n  t  S(   N(   t   _environmentt   NoneR   (    (    (    s+   /tmp/pip-unpacked-wheel-UAnTfW/kombu/syn.pyR   1   s    (   t   __doc__t
   __future__R    R   t   __all__R   R   R   R   R   R   (    (    (    s+   /tmp/pip-unpacked-wheel-UAnTfW/kombu/syn.pyt   <module>   s   				