File: //usr/lib64/python3.6/site-packages/zmq/devices/__pycache__/monitoredqueue.cpython-36.pyc
3
VS�_ � @ s( d Z ddlZdd� Zd dd�ZdgZdS )
ztpure Python monitored_queue function
For use when Cython extension is unavailable (PyPy).
Authors
-------
* MinRK
� Nc C sH | j � }|r*|d d� d d d� |d d�< |j|� |j|g| � d S )N� � ���)Zrecv_multipartZsend_multipart)ZinsZoutsZsides�prefix�swap_ids�msg� r �&/usr/lib64/python3.6/monitoredqueue.py�_relay s
r
� in� outc C s� | j tjko|j tjk}tj� }|j| tj� |j|tj� x@t|j� �}| |krbt| ||||� ||kr>t|| |||� q>W d S )N) �type�zmqZROUTERZPoller�registerZPOLLIN�dictZpollr
)Z in_socketZ
out_socketZ
mon_socketZ in_prefixZ
out_prefixr ZpollerZeventsr r r �monitored_queue s r )r r )�__doc__r r
r �__all__r r r r �<module> s