
    Ef                     &    d Z ddlZd Z	 ddZdgZy)ztpure Python monitored_queue function

For use when Cython extension is unavailable (PyPy).

Authors
-------
* MinRK
    Nc                     | j                         }|r|d d d d d   |d d |j                  |       |j                  |g|z          y )N   )recv_multipartsend_multipart)insoutssidesprefixswap_idsmsgs         </usr/lib/python3/dist-packages/zmq/devices/monitoredqueue.py_relayr      sN    



Cbq'$B$-BQ	&C(    c                    | j                   t        j                  k(  xr |j                   t        j                  k(  }t        j                         }|j	                  | t        j
                         |j	                  |t        j
                         	 t        |j                               }| |v rt        | ||||       ||v rt        || |||       @)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$9j*iJ:y*j(K r   r!   )s   ins   out)__doc__r   r   r!   __all__ r   r   <module>r%      s+    ) DJL" 
r   