
    9Cg:                        d dl mZ 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	d          Z ej        d          ZddZddZ G d de          ZddZddZdS )    )annotationsN)   
   )	ParamSpecPTargstuple[typing.Callable, dict]returnNonec            
     &  K   t          j        dt                     t          j                    4 d {V d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.func%typing.Callable[[], typing.Coroutine]r   r   c                ^   K    |              d {V  j                                          d S N)cancel_scopecancel)r   
task_groups    G/var/www/api/venv/lib/python3.11/site-packages/starlette/concurrency.pyrunz%run_until_first_complete.<locals>.run   s9      $&&LLLLLLL#**,,,,,    )r   r   r   r   )warningswarnDeprecationWarninganyiocreate_task_group
start_soon	functoolspartial)r	   r   r   kwargsr   s       @r   run_until_first_completer!      sy     MY  
 &(( J J J J J J JJ	- 	- 	- 	- 	- 	- ! 	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   5B  
B
B
r   typing.Callable[P, T]P.argsr    P.kwargsc                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(   #   sS       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*   iteratortyping.Iterator[T]c                L    	 t          |           S # t          $ r t          w xY wr   )nextStopIterationr*   )r/   s    r   _nextr4   .   s4    H~~   s    #typing.Iterable[T]typing.AsyncIterator[T]c                  K   t          |           }	 	 t          j                            t          |           d {V W V  n# t
          $ r Y d S w xY wBr   )iterr   r&   r'   r4   r*   )r/   as_iterators     r   iterate_in_threadpoolr:   8   sz       x..K	00DDDDDDDDDDDDD 	 	 	EE	s   .A 
AA)r	   r
   r   r   )r   r"   r	   r#   r    r$   r   r   )r/   r0   r   r   )r/   r5   r   r6   )
__future__r   r   systypingr   anyio.to_threadr   version_infor   typing_extensionsr   TypeVarr   r!   r(   	Exceptionr*   r4   r:   r.   r   r   <module>rC      s%   " " " " " "     



      w       ++++++IcNNFN3J J J J 7 7 7 7	 	 	 	 	Y 	 	 	        r   