
    /j                    L    S SK Jr  S SKrS SKJr  SS jr " S S5      rS	S jrg)
    )annotationsN)Anyc                R    U R                  5       (       a  g U R                  S 5        g N)	cancelled
set_result)futs    R/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/utils/aio/interval.py_finish_futr      s    
}}NN4    c                  F    \ rS rSrS	S jrS
S jrSS jrSS jrSS jrSr	g)Interval   c                H    Xl         SU l        SU l        S U l        S U l        g )Ng        r   )	_interval_last_sleep_i_handler_fut)selfintervals     r
   __init__Interval.__init__   s$    !4804	r   c                T   U R                   (       a  U R                  (       a  U R                  R                  5       (       d`  U R                  R                  5         [        R
                  " 5       nUR                  U R                  [        U R                   5      U l        g SU l	        g )Nr   )
r   r   r   cancelasyncioget_event_loop
call_laterr   r   r   )r   loops     r
   resetInterval.reset   sc    99t}}/F/F/H/HMM  "))+D OODNNKSDM Dr   c                ,  #    [         R                  " 5       nU R                  (       a  UR                  5       U l        U R                  UR                  5       -
  U R                  -   nUR                  U[        U R                  5      U l	         U R                  I S h  vN   U R                  R                  5         U =R                  S-  sl        UR                  5       U l        U R                  $  NT! U R                  R                  5         f = f7f)N   )r   r   r   create_futurer   timer   r   r   r   r   r   )r   r   delays      r
   tickInterval.tick   s     %%'**,DI$$tyy{2T^^CE OOE;		JDM'ii$$&GGqLG99;ww  $$&s1   BDC5 C3C5 #AD3C5 5DDc                    U $ r    r   s    r
   	__aiter__Interval.__aiter__.   s    r   c                >   #    U R                  5       I S h  vN $  N7fr   )r'   r+   s    r
   	__anext__Interval.__anext__1   s     YY[   s   )r   r   r   r   r   N)r   floatreturnNone)r2   r3   )r2   int)r2   r   )
__name__
__module____qualname____firstlineno__r   r    r'   r,   r/   __static_attributes__r*   r   r
   r   r      s    5! !r   r   c                    [        U 5      $ r   )r   )r   s    r
   r   r   5   s    Hr   )r	   zasyncio.Future[Any]r2   r3   )r   r1   r2   r   )
__future__r   r   typingr   r   r   r   r*   r   r
   <module>r=      s#    "  $! $!Nr   