f^UdZddlmZddlZddlmZdZ ddZee d<eeZdgZ yeZdgZ y) ztpure Python monitored_queue function For use when Cython extension is unavailable (PyPy). Authors ------- * MinRK )CallableN)monitored_queuec|j}|r|ddddd|dd|j||j|g|zy)N)recv_multipartsend_multipart)insoutssidesprefixswap_idsmsgs U/var/www/cvtools/html/venv/lib/python3.12/site-packages/zmq/devices/monitoredqueue.py_relayrsN   Cbq'$B$-BQ &C(c|jtjk(xr|jtjk(}tj}|j |tj |j |tj  t |j}||vrt|||||||vrt|||||@)N) typezmqROUTERPollerregisterPOLLINdictpollr) in_socket out_socket mon_socket in_prefix out_prefixrpollereventss r_monitored_queuer#s~~+M 3::0MH ZZ\F OOIszz* OOJ + fkkm$   9j*i J   :y*j( K rr)sinsout) __doc__typingrr zmq.backendr _backend_mqrr#__annotations____all__rrr+sU 6)DJ L !O  'O  r