← Back
Editing: monitoredqueue.cpython-311.pyc
� mc�c� � �( � d Z ddlZd� Z dd�ZdgZdS ) ztpure Python monitored_queue function For use when Cython extension is unavailable (PyPy). Authors ------- * MinRK � Nc � � | � � � }|r|d d� d d d� |d d�< |� |� � |� |g|z � � d S )N� ���)�recv_multipart�send_multipart)�ins�outs�sides�prefix�swap_ids�msgs �</usr/lib/python3/dist-packages/zmq/devices/monitoredqueue.py�_relayr sn � � � � � � �C�� ��b�q�b�'�$�$�B�$�-��B�Q�B������ � � � ���&��C� �(�(�(�(�(� � in� outc � � | j t j k o|j t j k }t j � � }|� | t j � � |� |t j � � t |� � � � � }| |v rt | ||||� � ||v rt || |||� � �P)N) �type�zmq�ROUTER�Poller�register�POLLIN�dict�pollr )� in_socket� out_socket� mon_socket� in_prefix� out_prefixr �poller�eventss r �monitored_queuer# s� � � �~���+�M� ��3�:�0M�H� �Z�\�\�F� �O�O�I�s�z�*�*�*� �O�O�J�� �+�+�+�L��f�k�k�m�m�$�$�� �� � � �9�j�*�i�� J� J� J� �� � � �:�y�*�j�(� K� K� K� Lr r# )r r )�__doc__r r r# �__all__� r r �<module>r' sV ��� � � � � �)� )� )� DJ�L� L� L� L�" � ���r
Save File
Cancel