
    ^h                     \    % S r SSKJr  SSKrSSKJr  S r SS jr\\	S'   \b  \rO\rS/r
g)	ztpure Python monitored_queue function

For use when Cython extension is unavailable (PyPy).

Authors
-------
* MinRK
    )CallableN)monitored_queuec                     U R                  5       nU(       a  US S S S S2   US S& UR                  U5        UR                  U/U-   5        g )N   )recv_multipartsend_multipart)insoutssidesprefixswap_idsmsgs         T/home/james-whalen/.local/lib/python3.13/site-packages/zmq/devices/monitoredqueue.py_relayr      sN    



Cbq'$B$-BQ	&C(    c                    U R                   [        R                  :H  =(       a    UR                   [        R                  :H  n[        R                  " 5       nUR	                  U [        R
                  5        UR	                  U[        R
                  5         [        UR                  5       5      nX;   a  [        XX#U5        X;   a  [        XX$U5        M?  )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::0MHZZ\F
OOIszz*
OOJ

+
fkkm$9*J:*(K r   r   )s   ins   out)__doc__typingr   r   zmq.backendr   _backend_mqr   r#   __annotations____all__ r   r   <module>r+      sK     
 6) DJL   !O 'O 
r   