o i @sdZddlZddlmZmZmZmZddlZddlZddl m Z ddl m Z Gddde Z deed e fd d Zd eeed e fd dZe dddded ee fddZe ddejeded e fddZ ddejded ee ee ffddZd dgZdS)zJModule holding utility and convenience functions for zmq event monitoring.N) AwaitableListUnionoverload) TypedDict)_check_versionc@s&eZdZUeed<eed<eed<dS)_MonitorMessageeventvalueendpointN)__name__ __module__ __qualname__int__annotations__bytesrrL/var/www/edux/Edux_v2/venv/lib/python3.10/site-packages/zmq/utils/monitor.pyrs  rmsgreturncCs\t|dkst|ddkrtd|td|d\}}t|t||dd}|S)adecode zmq_monitor event messages. Parameters ---------- msg : list(bytes) zmq multipart message that has arrived on a monitor PAIR socket. First frame is:: 16 bit event id 32 bit event value no padding Second frame is the endpoint as a bytestring Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. rz Invalid event message format: %sz=hi)r r r )len RuntimeErrorstructunpackzmqEvent)revent_idr r rrrparse_monitor_messages r awaitable_msgcs|IdH}t|S)zyLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r )r!rrrr_parse_monitor_msg_async5s r"socketzzmq.asyncio.SocketflagscCdSNrr#r$rrrrecv_monitor_messageBr(cCr%r&rr'rrrr(Jr)cCs.tdd||}t|trt|St|S)uReceive and decode the given raw message from the monitoring socket and return a dict. Requires libzmq ≥ 4.0 The returned dict will have the following entries: event : int, the event id as described in libzmq.zmq_socket_monitor value : int, the event value associated with the event, see libzmq.zmq_socket_monitor endpoint : string, the affected endpoint .. versionchanged:: 23.1 Support for async sockets added. When called with a async socket, returns an awaitable for the monitor message. Parameters ---------- socket : zmq PAIR socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : bitfield (int) standard zmq recv flags Returns ------- event : dict event description as dict with the keys `event`, `value`, and `endpoint`. )rzlibzmq event API)rrecv_multipart isinstancerr"r )r#r$rrrrr(Rs   )r)__doc__rtypingrrrrr zmq.asyncio zmq._typingr zmq.errorrrrr r"rr(Socket__all__rrrrsR         ,