sj'2ddlmZGddZeZy))schedule_coroutinec,eZdZdZdZdZdZddZy)PublishManagerc g|_d|_y)N) protocols publishCount)selfs ;/DATA/.local/lib/python3.12/site-packages/wslink/publish.py__init__zPublishManager.__init__sc:|jj|yN)rappendr protocols r registerProtocolzPublishManager.registerProtocol s h'r cX||jvr|jj|yyr)rremovers r unregisterProtocolz!PublishManager.unregisterProtocols% t~~ % NN ! !( + &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 Nc |jD]^}d|d|j}|jjt d|j |||||jj `y)Nzpublish::r) client_idskip_last_active_client done_callback)rr network_monitoron_enterrsendWrappedMessageon_exit)r topicdatarrrrpcids r publishzPublishManager.publishsjHugQt'8'8&9:E  $ $ - - / ++#(?&66>>  'r )NF)__name__ __module__ __qualname__r rrrr'rr r rrs(,r rN)rrpublishManagerrr r r-s !!J !r