
    /jQ              
           S SK r S SKJrJr  S SKJrJrJr  \" S5      r " S S\\   5      r	S\
S\\/ \\\\4   4   /\	\   4   4S	 jrg)
    N)Callable	Coroutine)AnyGenericTypeVarTc                       \ rS rSrS\/ \\\\4   4   S\SS4S jr	S\
R                  \   4S jrS\
R                  \   4S jrSS	 jrS\4S
 jrS\
R                  \   4S jrSrg)	Debounced   funcdelayreturnNc                 *    Xl         X l        S U l        g N)_func_delay_task)selfr   r   s      R/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/utils/aio/debounce.py__init__Debounced.__init__	   s    
-1
    c                    ^  T R                  5         S[        4U 4S jjn[        R                  " U" 5       5      T l        T R                  $ )Nr   c                     >#    [         R                  " T R                  5      I S h  vN   T R                  5       I S h  vN $  N N7fr   )asynciosleepr   r   r   s   r   _func_with_timer,Debounced.schedule.<locals>._func_with_timer   s3     --,,,%% -%s    $AAAA AA)cancelr   r   create_taskr   )r   r   s   ` r   scheduleDebounced.schedule   s:    	& 	& (()9);<
zzr   c                     U R                  5         [        R                  " U R                  5       5      U l        U R                  $ r   )r    r   r!   r   r   r   s    r   runDebounced.run   s-    ((6
zzr   c                     U R                   bB  U R                   R                  5       (       d"  U R                   R                  5         S U l         g g g r   )r   doner    r   s    r   r    Debounced.cancel   s;    ::!$**//*;*;JJDJ +<!r   c                     U R                   S L=(       aE    U R                   R                  5       (       + =(       a    U R                   R                  5       (       + $ r   )r   r(   	cancelledr   s    r   
is_runningDebounced.is_running#   s9    zz%^djjoo.?*?^

H\H\H^D^^r   c                 "    U R                  5       $ r   )r%   r   s    r   __call__Debounced.__call__&   s    xxzr   )r   r   r   )r   N)__name__
__module____qualname____firstlineno__r   r   r   r   floatr   r   Taskr"   r%   r    boolr,   r/   __static_attributes__ r   r   r
   r
      s    2Xb)CaK*@&@A 2% 2TX 2
',,q/ W\\!_ 
_D _',,q/ r   r
   r   r   c                 t   ^  S[         / [        [        [        [        4   4   S[        [           4U 4S jjnU$ )Nr   r   c                    > [        U T5      $ r   )r
   )r   r   s    r   	decoratordebounced.<locals>.decorator+   s    u%%r   )r   r   r   r   r
   )r   r<   s   ` r   	debouncedr>   *   s7    &YsC{%;!;< &1 & r   )r   collections.abcr   r   typingr   r   r   r   r
   r5   r>   r9   r   r   <module>rA      sg     / ( (CL
 DU x"iS!6L2L)M(NPYZ[P\(\] r   