
    )O=d                        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dS )    N)   
   )	ParamSpecTPargsreturnc            
      f  K   t          j        dt                     t          j                    4 d {V dt
          j        g t
          j        f         dd ffd}| D ]+\  }}                    |t          j
        |fi |           ,	 d d d           d {V  d S # 1 d {V swxY w Y   d S )NzOrun_until_first_complete is deprecated and will be removed in a future version.funcr	   c                 ^   K    |              d {V  j                                          d S N)cancel_scopecancel)r   
task_groups    ?D:\Sites\api_v1\venv\Lib\site-packages\starlette/concurrency.pyrunz%run_until_first_complete.<locals>.run   s9      $&&LLLLLLL#**,,,,,    )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     M	3   &(( J J J J J J JJ	-FOB0@,@A 	-d 	- 	- 	- 	- 	- 	- ! 	J 	JLD&!!#y'8'H'H'H'HIIII	JJ J J J J J J J J J J J J J J J J J J J J J J J J J J J J Js   AB  
B*-B*r   r   c                 h   K   |rt          j        | fi |} t          j        j        | g|R   d {V S r   )r   r   r   	to_threadrun_sync)r   r   r   s      r   run_in_threadpoolr$   #   sU        1 0000)$66666666666r   c                       e Zd ZdS )_StopIterationN)__name__
__module____qualname__ r   r   r&   r&   ,   s        Dr   r&   iteratorc                 L    	 t          |           S # t          $ r t          w xY wr   )nextStopIterationr&   r+   s    r   _nextr0   0   s4    H~~   s    #c                   K   	 	 t           j                            t          |            d {V W V  n# t          $ r Y d S w xY wBr   )r   r"   r#   r0   r&   r/   s    r   iterate_in_threadpoolr2   :   sm      	00AAAAAAAAAAAAA 	 	 	EE	s   .4 
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       ++++++ FN3IcNNJ&,v7L*M JRV J J J J"7
/!Q$
7()7:;(77 7 7 7	 	 	 	 	Y 	 	 	FOA& 1    oa !     r   