^h SrSSKJr SSKrSSKJrJrJr SSKrSSK rSSK J r "SS\5r SSjr SS jr\SSS jj5r\SSS jj5rSSS jjrS S/rg)zJModule holding utility and convenience functions for zmq event monitoring.) annotationsN) Awaitable TypedDictoverload)_check_versionc4\rSrSr%S\S'S\S'S\S'Srg) _MonitorMessageinteventvaluebytesendpointN)__name__ __module__ __qualname____firstlineno____annotations____static_attributes__rK/home/james-whalen/.local/lib/python3.13/site-packages/zmq/utils/monitor.pyr r s J JOrr c[U5S:wd[US5S:wa[SU35e[R"SUS5up[R "U5[R "U5USS.nU$)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`. rzInvalid event message format: z=hi)r r r)len RuntimeErrorstructunpackzmqEvent)msgevent_idr r s rparse_monitor_messager%st* 3x1}CF q(;C5ABBmmE3q62OH8$5!FE Lrc8# UIShvN n[U5$N7f)zqLike parse_monitor_msg, but awaitable Given awaitable message, return awaitable for the parsed monitor message. N)r%) awaitable_msgr#s r_parse_monitor_msg_asyncr(6s C  %% s cgNrsocketflagss rrecv_monitor_messager.Cs"%rcgr*rr+s rr.r.Jsrc[SS5 URU5n[U[5(a [ U5$[ U5$)u%Receive 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 : str 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.Socket The PAIR socket (created by other.get_monitor_socket()) on which to recv the message flags : 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-r#s rr.r.QsGD6-.    &C#y!!',, ! %%rr%r.)r#z list[bytes]returnr )r'zAwaitable[list[bytes]]r4r )r)r,zzmq.asyncio.Socketr-r r4zAwaitable[_MonitorMessage])r,zzmq.Socket[bytes]r-r r4r )r,z zmq.Socketr-r r4z,_MonitorMessage | Awaitable[_MonitorMessage])__doc__ __future__rrtypingrrrr! zmq.asyncio zmq.errorrr r%r(r.__all__rrrr;sP # 11 $i @ &) & & % % % % %     ,& ,& ,&2,&^ #$: ;r