
    /j                         S SK r S SKrS SKJr  S\ R                  \   SS4S jrS\ R                  \   S\SS4S jr\rg)	    N)Anyfuturesreturnc                    #    [         R                  " 5       n/ nU  Ha  nUR                  5       n[        R                  " [
        U5      nUR                  XE45        UR                  U5        UR                  5         Mc      U H  u  pFUI S h  vN   M     [        U 5       H  u  psX'   u  peUR                  U5        M     g  N4! [        U 5       H  u  psX'   u  peUR                  U5        M     f = f7fN)asyncioget_running_loopcreate_future	functoolspartial_release_waiterappendadd_done_callbackcancel	enumerateremove_done_callback)r   loopwaitersfutwaitercb_is           O/app/agent/.venv/lib/python3.13/site-packages/livekit/agents/utils/aio/utils.pycancel_and_waitr      s     ##%DG##%7|$b!

 ) IFLL !  (FAJEA$$R( ) (FAJEA$$R( )s0   A?C5C CC ,C5C -C22C5r   r   c                 R    U R                  5       (       d  U R                  S 5        g g r   )done
set_result)r   r   s     r   r   r      s     ;;==$     )r   r   typingr   Futurer   r   gracefully_cancel r   r   <module>r$      sU      )GNN3$7 )D )( GNN3/  S  T  
 $ r   