o ṏi@s^UdZddlmZddlZddlmZddZ d d d Zee d <edur(eZneZd gZ dS) ztpure Python monitored_queue function For use when Cython extension is unavailable (PyPy). Authors ------- * MinRK )CallableN)monitored_queuecCsH|}|r|ddddd|dd<||||g|dS)N)recv_multipartsend_multipart)insoutssidesprefixswap_idsmsgrW/home/ubuntu/veenaModal/venv/lib/python3.10/site-packages/zmq/devices/monitoredqueue.py_relays  rinoutcCs||jtjko |jtjk}t}||tj||tj t|}||vr1t|||||||vr=t|||||q)N) typezmqROUTERPollerregisterPOLLINdictpollr) in_socket out_socket mon_socket in_prefix out_prefixr pollereventsrrr_monitored_queues r"r)rr) __doc__typingrr zmq.backendr _backend_mqrr"__annotations____all__rrrrs