+ ~jz^RIt^RIt^RIHtHtHtHtHtHt^RI H t ]!RRR7t !RR]] ,4t R#) N)CallableDictSetOptionalGenericTypeVar)loggerT_contraT) contravariantca]tRt^ toV3RlRltV3RlRltR V3RlRlltR V3RlR lltV3R lR ltR t Vt R#) EventEmitterc<V^8dQhRR/#)returnN)format __classdict__s"n/Users/mitch_tango/dev/rabbit-r1-livekit/agent/.venv/lib/python3.14/site-packages/livekit/rtc/event_emitter.py __annotate__EventEmitter.__annotate__ s==$=c $\4VnR#)z, Initialize a new instance of EventEmitter. N)dict_events)selfs&r__init__EventEmitter.__init__ s 7;f rc$<V^8dQhRS[RR/#)reventrN)r )rrs"rrrs-F-F(-Fd-Frc WP9EdVPV,P4pVFp\P!V4pVPP 4p\ ;QJdRV4F 'gK RM RM !RV44pV'd V!V!KxVUu.uF.pVPVPVP39gK,VNK0 p p\V 4p \\V4V 4p VRV p V!V !K R#R#uupi \dh\d\P!RT 24EKi;i)a Trigger all callbacks associated with the given event. Args: event (T): The event to emit. *args: Positional arguments to pass to the callbacks. Example: Basic usage of emit: ```python emitter = EventEmitter[str]() def greet(name): print(f"Hello, {name}!") emitter.on('greet', greet) emitter.emit('greet', 'Alice') # Output: Hello, Alice! ``` c3R"TFqPVP8HxK R#5iN)kindVAR_POSITIONAL).0ps& r $EventEmitter.emit..-s%Q&Qff0@0@&@&s%'TFNzfailed to emit event )rcopyinspect signature parametersvaluesanyr#POSITIONAL_ONLYPOSITIONAL_OR_KEYWORDlenmin TypeError Exceptionr exception) rrargs callablescallbacksigparams has_varargsr&positional_params num_paramsnum_args callback_argss &&* remitEventEmitter.emits3* LL  U+002I%F!++H5C ^^224F"%#%Q&%Q###%Q&%Q"QK" $&,-%+ vv!*;*;Q=T=T)UUA%+*- &)):%; #&s4y*#=(,Yh  -0%& !-! F$$'.once_callbackks .$)&)rc0V^8dQhR\R\/#rr8rr)rs"rr'EventEmitter.once..__annotate__r  H  rc,<SPSV4V#r")oncer8rrs&r decorator$EventEmitter.once..decoratorrs %*ron)rrr8rSrIsfff @rrQEventEmitter.once@s;R   * *775-0 0   rc<<V^8dQhRS[RS[S[,RS[/#rCrD)rrs"rrrxs'777HX,>7(7rc aaVet\P!V4'd \R4hSSP9d\ 4SPS&SPS,P V4V#RVV3RllpV#)a Register a callback to be called whenever the event is emitted. If a callback is provided, it registers the callback directly. If no callback is provided, it returns a decorator for use with function definitions. Args: event (T): The event to listen for. callback (Callable, optional): The callback to register. Defaults to None. Returns: Callable: The registered callback or a decorator if callback is None. Example: Using on with a direct callback: ```python emitter = EventEmitter[str]() def greet(name): print(f"Hello, {name}!") emitter.on('greet', greet) emitter.emit('greet', 'Charlie') # Output: Hello, Charlie! ``` Using on as a decorator: ```python emitter = EventEmitter[str]() @emitter.on('greet') def greet(name): print(f"Hello, {name}!") emitter.emit('greet', 'Charlie') # Output: Hello, Charlie! ``` zsCannot register an async callback with `.on()`. Use `asyncio.create_task` within your synchronous callback instead.c0V^8dQhR\R\/#rLrM)rs"rr%EventEmitter.on..__annotate__rOrc,<SPSV4V#r"rUrRs&rrS"EventEmitter.on..decoratorsx(r)asyncioiscoroutinefunction ValueErrorrsetadd)rrr8rSsff& rrVEventEmitter.onxs|N  **844 JDLL(&)e U# LL  # #H -O   rc*<V^8dQhRS[RS[RR/#)rrr8rN)r r)rrs"rrrs"222X2$2rc nWP9d%VPV,PV4R#R#)a Unregister a callback from an event. Args: event (T): The event to stop listening to. callback (Callable): The callback to remove. Example: Removing a callback: ```python emitter = EventEmitter[str]() def greet(name): print(f"Hello, {name}!") emitter.on('greet', greet) emitter.off('greet', greet) emitter.emit('greet', 'Dave') # No output, callback was removed ``` N)rdiscard)rrr8s&&&rrGEventEmitter.offs*, LL LL  ' ' 1 !r)rr") __name__ __module__ __qualname____firstlineno__rr@rQrVrG__static_attributes____classdictcell__)rs@rr r s<== -F-F^66p77r22rr ) r*r^typingrrrrrrlogr r r rrrrps3BB :T 2~278$~2r