ó
    ´Õi^  ã                  óº   • S SK Jr  S SKrS SKrS SKJrJrJrJrJ	r	  S SK
JrJr  S SKr\" S5      r\" S5      rSS jrSS jr " S	 S
\5      rSS jr    SS jrg)é    )ÚannotationsN)ÚAsyncIteratorÚCallableÚ	CoroutineÚIterableÚIterator)Ú	ParamSpecÚTypeVarÚPÚTc            
   ‡  óP  ^#   • [         R                  " S[        5        [        R                  " 5        IS h  v•N mSU4S jjnU  H,  u  p#TR                  U[        R                  " U40 UD65        M.     S S S 5      IS h  v•N   g  NO N! , IS h  v•N  (       d  f       g = f7f)NzOrun_until_first_complete is deprecated and will be removed in a future version.c              “  ód   >#   • U " 5       I S h  v•N   TR                   R                  5         g  N7f©N)Úcancel_scopeÚcancel)ÚfuncÚ
task_groups    €ÚR/home/mande/repo/quber/.venv/lib/python3.13/site-packages/starlette/concurrency.pyÚrunÚ%run_until_first_complete.<locals>.run   s&   øé € Ù“&�LˆLØ×#Ñ#×*Ñ*Õ,ñ ùs   ƒ0Ž.� 0)r   zCallable[[], Coroutine]ÚreturnÚNone)ÚwarningsÚwarnÚDeprecationWarningÚanyioÚcreate_task_groupÚ
start_soonÚ	functoolsÚpartial)Úargsr   r   Úkwargsr   s       @r   Úrun_until_first_completer#      sr   øé € Ü‡M‚MØYÜôô
 ×&Ò&×(Ô(¨J÷	-ó !‰LˆDØ×!Ñ! #¤y×'8Ò'8¸Ñ'HÀÑ'HÖIñ !÷ )×(×(×(×(Ó(üsD   ƒ5B&¸B¹B&¼;BÁ7B&ÂB
ÂB&Â
B&ÂB#ÂBÂB#ÂB&c              �  ó�   #   • [         R                  " U /UQ70 UD6n [        R                  R	                  U 5      I S h  v•N $  N7fr   )r   r    r   Ú	to_threadÚrun_sync)r   r!   r"   s      r   Úrun_in_threadpoolr'      s:   é € Ü×Ò˜TÐ3 DÒ3¨FÑ3€DÜ—‘×)Ñ)¨$Ó/×/Ð/Ñ/ùs   ‚=A¿AÁ Ac                  ó   • \ rS rSrSrg)Ú_StopIterationé#   © N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__static_attributes__r+   ó    r   r)   r)   #   s   † Úr1   r)   c                óB   •  [        U 5      $ ! [         a    [        ef = fr   )ÚnextÚStopIterationr)   )Úiterators    r   Ú_nextr6   '   s&   € ðÜ�H‹~ÐøÜó ÜÐðús   ‚
 �c               óª   #   • [        U 5      n  [        R                  R                  [        U5      I S h  v•N 7v •  M2   N	! [
         a     g f = f7fr   )Úiterr   r%   r&   r6   r)   )r5   Úas_iterators     r   Úiterate_in_threadpoolr:   1   sK   é € ô �x“.€KØ
ð	ÜŸ™×0Ñ0´¸ÓD×DÓDñ áDøÜó 	Ùð	üs7   ‚A�'A ·A¸A ¿AÁA Á
AÁAÁAÁA)r!   ztuple[Callable, dict]r   r   )r   zCallable[P, T]r!   zP.argsr"   zP.kwargsr   r   )r5   zIterator[T]r   r   )r5   zIterable[T]r   zAsyncIterator[T])Ú
__future__r   r   r   Úcollections.abcr   r   r   r   r   Útypingr	   r
   Úanyio.to_threadr   r   r   r#   r'   Ú	Exceptionr)   r6   r:   r+   r1   r   Ú<module>r@      s]   ðÝ "ã Û ß RÕ Rß %ã áˆcƒN€ÙˆCƒL€ôJô 0ô
	�Yô 	ôðØðàõr1   