ї j╔ЦС┼≈UdZddlmZddlZddlmZmZddlmZej і╚Z iZded<dd└Z dd└Zdd└Zddd└ZdS)a╪Lightweight in-process event bus for decoupling modules. Usage:: from shared.events import on, emit # subscriber (e.g. in dispatch module init) on("identity_matched", lambda **kw: ingest_to_queue(**kw)) # publisher (e.g. in face module) emit("identity_matched", owner_key=..., items=...) Events are dispatched synchronously in the caller's thread. Subscriber exceptions are logged but never propagate to the publisher. И)зannotationsN)зAnyзCallable)зloggerz#dict[str, list[Callable[..., Any]]]з _handlersз event_nameзstrзhandlerЗCallable[..., Any]зreturnзNonecС╒≈t5t═|gі╚═|і╚dddі╚dS#1swxYwYdS)z=Register *handler* to be called when *event_name* is emitted.N)з_lockrз setdefaultзappend)rr s З//home/longshao/multi-rider-rag/shared/events.pyзonrs░─Е П=П=щвр≤Z╗я,т,в3р3╟Gя<т<п<П=П=П=Я=Т=П=П=П=П=П=П=П=ЬЬЬП=П=П=П=П=П=s┬/AаAаAcСл≈t5t═|і╚}|r' |═|і╚n#t$rYnwxYwdddі╚dS#1swxYwYdS)z4Remove a previously registered handler (idempotent).N)rrзgetзremoveз ValueError)rr з listenerss rзoffr"sа─Е ППщ≈M▓M═*я-т-┬ ьП П ьв р ═я)т)п)п)ЬщП П П ь░П ЬЬЬПППЯТПППППППЬЬЬППППППs1┬Aі<╩A╪ A аAаA а AаAа AзkwargsrcСЗ≈t5tt═|gі╚і╚}dddі╚n#1swxYwY|D]0} |di|є▌▄#t$rtjd|і╚Y▄-wxYwdS)zцFire *event_name*, passing *kwargs* to every registered handler. Exceptions in individual handlers are logged and swallowed so that one broken subscriber cannot break the publisher. Nzevent handler error for %r╘)rзlistrrз Exceptionrз exception)rrrr s rзemitr -sО─У П8П8щ²÷ ═z╟2я6т6я7т7┬ П8П8П8Я8Т8П8П8П8П8П8П8ЬЬЬП8П8П8П8ЮПGПG┬П Gь┬Gпп░fппппЬщП GП GП Gщтп9╦:яFтFпFпFпFП GЬЬЬПGПGs!┬)=ҐAаAа AаA8а7A8З str | NonecСЄ≈t5|─t═і╚nt═|dі╚dddі╚dS#1swxYwYdS)zBRemove all handlers for *event_name*, or all handlers if ``None``.N)rrзclearзpop)rs rr#r#<s≥─Е П,П,ьпщ▐O┼OятппЕ▐M┼M≤*═dя+т+п+П ,П,П,Я,Т,П,П,П,П,П,П,П,ЬЬЬП,П,П,П,П,П,s┬8A а AаA)rr r rrr )rr rrrr )N)rr!rr )з__doc__з __future__rз threadingзtypingrrзshared.config.configrзLockrrз__annotations__rrr r#rСrЗr-sАППППП #п"п"п"п"п"Юпппь п п п п п п п Ю'п'п'п'п'п'Ю┬ ▄ят─ь13─ п3п3п3я3П=П=П=П=ПППППGПGПGПGП,П,П,П,П,П,П,r,