
    df                        d dl Z d dlZd dlZd dlZd dlZej
                  dk\  rd dlmZ nd dlmZ  ej                  d      Z	 ed      Z
dej                  ej                  ef   ddfdZd	ej                  e
e	f   de
j                  d
e
j                   de	fdZ G d de      Zdej(                  e	   de	fdZdej(                  e	   dej,                  e	   fdZy)    N)   
   )	ParamSpecTPargsreturnc            
        K   t        j                  dt               t        j                         4 d {   dt
        j                  g t
        j                  f   dd ffd}| D ]+  \  }}j                  |t        j                  |fi |       - d d d       d {    y 7 p7 # 1 d {  7  sw Y   y xY ww)NzOrun_until_first_complete is deprecated and will be removed in a future version.funcr	   c                 d   K    |         d {    j                   j                          y 7 wN)cancel_scopecancel)r   
task_groups    N/home/api-vastappli/venv/lib/python3.12/site-packages/starlette/concurrency.pyrunz%run_until_first_complete.<locals>.run   s'     &LL##**, s   0. 0)warningswarnDeprecationWarninganyiocreate_task_grouptypingCallable	Coroutine
start_soon	functoolspartial)r   r   r   kwargsr   s       @r   run_until_first_completer      s     MM	3 &&( J JJ	-FOOB0@0@,@A 	-d 	- ! 	JLD&!!#y'8'8'H'HI	JJ J J J J J JsE   3C B'C AB+C !B)"C )C +B=1B42B=9C r   r   c                    K   |rt        j                  | fi |} t        j                  j                  | g|  d {   S 7 wr   )r   r   r   	to_threadrun_sync)r   r   r   s      r   run_in_threadpoolr#   #   s@        00))$66666s   <AAAc                       e Zd Zy)_StopIterationN)__name__
__module____qualname__     r   r%   r%   ,   s    r*   r%   iteratorc                 @    	 t        |       S # t        $ r t        w xY wr   )nextStopIterationr%   r+   s    r   _nextr0   0   s&    H~ s   
 c                   K   	 	 t         j                  j                  t        |        d {    17 # t        $ r Y y w xY wwr   )r   r!   r"   r0   r%   r/   s    r   iterate_in_threadpoolr2   :   sC      	00AAA A 		s1   A'7 57 A7 	A AAA)r   sysr   r   r   version_infor   typing_extensionsTypeVarr   r   Tupler   dictr   r   r   r#   	Exceptionr%   Iteratorr0   AsyncIteratorr2   r)   r*   r   <module>r<      s     
   w + FNN3cNJ&,,v7L*M JRV J"7
//!Q$
7()7:;((77	Y 	FOOA& 1 ooa !r*   