U
    lufý  ã                   @   s(   d Z ddlZdd„ Zd	dd„ZdgZdS )
ztpure Python monitored_queue function

For use when Cython extension is unavailable (PyPy).

Authors
-------
* MinRK
é    Nc                 C   sH   |   ¡ }|r*|d d… d d d… |d d…< | |¡ | |g| ¡ d S )Né   éÿÿÿÿ)Zrecv_multipartZsend_multipart)ZinsZoutsZsidesÚprefixÚswap_idsÚmsg© r   ú>/tmp/pip-unpacked-wheel-h6ekxre8/zmq/devices/monitoredqueue.pyÚ_relay   s
    
r	   ó   inó   outc                 C   s~   | j tjko|j tjk}t ¡ }| | tj¡ | |tj¡ t| ¡ ƒ}| |kr`t| ||||ƒ ||kr<t|| |||ƒ q<d S )N)	ÚtypeÚzmqZROUTERZPollerÚregisterÚPOLLINÚdictÚpollr	   )Z	in_socketZ
out_socketZ
mon_socketZ	in_prefixZ
out_prefixr   ZpollerÚeventsr   r   r   Úmonitored_queue   s    r   )r
   r   )Ú__doc__r   r	   r   Ú__all__r   r   r   r   Ú<module>   s   	   ÿ
