)j'@ddlmZGddZeZdS))schedule_coroutinec.eZdZdZdZdZdZddZdS) PublishManagerc"g|_d|_dS)N) protocols publishCount)selfs H/DATA/AppData/hermes/venv/lib/python3.11/site-packages/wslink/publish.py__init__zPublishManager.__init__sc:|j|dSN)rappendr protocols r registerProtocolzPublishManager.registerProtocol s h'''''r cP||jvr|j|dSdSr)rremovers r unregisterProtocolz!PublishManager.unregisterProtocols3 t~ % % N ! !( + + + + + & %r c|S)zDeprecated method, keeping it to avoid breaking compatibility Now that we use msgpack to pack/unpack messages, We can have binary data directly in the object itself, without needing to transfer it separately from the rest.)r payloads r addAttachmentzPublishManager.addAttachments r NFc |jD]M}d|d|j}|jt d|j|||||jjNdS)Nzpublish::r) client_idskip_last_active_client done_callback)rr network_monitoron_enterrsendWrappedMessageon_exit)r topicdatarrrrpcids r publishzPublishManager.publishs  H:u::t'8::E  $ - - / / / +#(?&6>       r )NF)__name__ __module__ __qualname__r rrrr'rr r rrsd(((,,,r rN)rrpublishManagerrr r r-sS !!!!!!!!J !!r