ó
O'—^c           @@  s}   d  d l  m Z d  d l m Z d d d g Z d g Z d e f d „  ƒ  YZ d „  Z	 e
 d „ Z d	 e f d
 „  ƒ  YZ d S(   i    (   t   absolute_import(   t   Queuet   Clientt   Listenert   Pipec           B@  sM   e  Z d d d  d „ Z d „  Z d „  Z e d „  ƒ Z d „  Z d „  Z	 RS(   i   c         C@  s   t  | ƒ |  _ d  S(   N(   R   t   _backlog_queue(   t   selft   addresst   familyt   backlog(    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   __init__-   s    c         C@  s   t  |  j j ƒ  Œ  S(   N(   t
   ConnectionR   t   get(   R   (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   accept0   s    c         C@  s   d  |  _ d  S(   N(   t   NoneR   (   R   (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   close3   s    c         C@  s   |  j  S(   N(   R   (   R   (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   <lambda>6   t    c         C@  s   |  S(   N(    (   R   (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt	   __enter__8   s    c         G@  s   |  j  ƒ  d  S(   N(   R   (   R   t   exc_info(    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   __exit__;   s    N(
   t   __name__t
   __module__R   R
   R   R   t   propertyR   R   R   (    (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyR   +   s   			c         C@  s3   t  ƒ  t  ƒ  } } |  j | | f ƒ t | | ƒ S(   N(   R   t   putR   (   R   t   _int   _out(    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyR   ?   s    c         C@  s/   t  ƒ  t  ƒ  } } t | | ƒ t | | ƒ f S(   N(   R   R   (   t   duplext   at   b(    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyR   E   s    R   c           B@  s&   e  Z d  „  Z d d „ Z d „  Z RS(   c         C@  s<   | |  _  | |  _ | j |  _ |  _ | j |  _ |  _ d  S(   N(   R   R   R   t   sendt
   send_bytesR   t   recvt
   recv_bytes(   R   R   R   (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyR
   L   s    		g        c         C@  so   |  j  j ƒ  d k r t S| d k r) t S|  j  j j ƒ  |  j  j j | ƒ |  j  j j ƒ  |  j  j ƒ  d k S(   Ni    g        (   R   t   qsizet   Truet   Falset	   not_emptyt   acquiret   waitt   release(   R   t   timeout(    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   pollR   s    c         C@  s   d  S(   N(    (   R   (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyR   \   s    (   R   R   R
   R*   R   (    (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyR   J   s   	
N(   t
   __future__R    t   billiard.fiveR   t   __all__R   t   familiest   objectR   R   R#   R   R   (    (    (    s;   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/connection.pyt   <module>"   s   		