o
    ªZh  ã                   @   s^   U d Z ddlmZ ddlZddlmZ dd„ Z	dd	d
„Zee	d< edur(eZneZdgZ
dS )ztpure Python monitored_queue function

For use when Cython extension is unavailable (PyPy).

Authors
-------
* MinRK
é    )ÚCallableN)Úmonitored_queuec                 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	   úQ/var/www/html/lang_env/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Ú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   r   )Ú__doc__Útypingr   r   Zzmq.backendr   Z_backend_mqr   r   Ú__annotations__Ú__all__r	   r	   r	   r
   Ú<module>   s    	
ÿ
