o
    ¹iý  ã                   @   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é   éÿÿÿÿ)Úrecv_multipartÚsend_multipart)ÚinsÚoutsÚsidesÚprefixÚswap_idsÚmsg© r   úU/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/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| ¡ ƒ}| |v r1t| ||||ƒ ||v r=t|| |||ƒ q)N)	ÚtypeÚzmqÚROUTERÚPollerÚregisterÚPOLLINÚdictÚpollr   )Ú	in_socketÚ
out_socketÚ
mon_socketÚ	in_prefixÚ
out_prefixr
   ÚpollerÚeventsr   r   r   Úmonitored_queue   s   ûr    )r   r   )Ú__doc__r   r   r    Ú__all__r   r   r   r   Ú<module>   s    	
ÿ
