qipddlZddlZddlmZmZmZmZmZmZddl m Z eddZ Gdd ee Z y) N)CallableDictSetOptionalGenericTypeVar)loggerT_contraT) contravariantcpeZdZd dZdeddfdZd dedeedefdZd dedeedefdZ dededdfd Z y) EventEmitterreturnNc"t|_y)z< Initialize a new instance of EventEmitter. N)dict_events)selfs K/opt/pipecat/venv/lib/python3.12/site-packages/livekit/rtc/event_emitter.py__init__zEventEmitter.__init__ s 7;f eventc"||jvr|j|j}|D]} tj|}|jj }t d|D}|r||n]|Dcgc](}|j|j|jfvr|*} }t| } tt|| } |d| } || yycc}w#t$rt$rtjd|YwxYw)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! ``` c3NK|]}|j|jk(ywN)kindVAR_POSITIONAL).0ps r z$EventEmitter.emit..-s%QQaff0@0@&@%Qs#%Nzfailed to emit event )rcopyinspect signature parametersvaluesanyrPOSITIONAL_ONLYPOSITIONAL_OR_KEYWORDlenmin TypeError Exceptionr exception) rrargs callablescallbacksigparams has_varargsrpositional_params num_paramsnum_args callback_argss remitzEventEmitter.emits&* DLL  U+002I% FF!++H5C ^^224F"%%Q&%Q"QK" $&,- ! vv!*;*;Q=T=T)UU-)- &)):%; #&s4y*#=(,Yh  -0% F !-! F$$'.once_callbackks .$)&)rr/rc,j||Sr)oncer/rrs r decoratorz$EventEmitter.once..decoratorrs %*r)onr)rrr/r@r<s``` @rr>zEventEmitter.once@s?R   *775-0 0 H   rc|etj|r tdjvrt j<jj ||Sdt dt ffd }|S)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.r/rc,j||Sr)rAr?s rr@z"EventEmitter.on..decoratorsx(r)asyncioiscoroutinefunction ValueErrorrsetaddr)rrr/r@s`` rrAzEventEmitter.onxsN  **84 JDLL(&)e U# LL  # #H -O H   rc^||jvr|j|j|yy)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)rrr/s rr:zEventEmitter.offs,, DLL LL  ' ' 1 !r)rNr) __name__ __module__ __qualname__rr r7rrr>rAr:rrrr sx= -F(-Fd-F^6(6hx.@6H6p77HX,>7(7r22X2$2rr) r!rDtypingrrrrrrlogr r rrNrrrQs3BB :T 2~278$~2r