+
    NV-j¥  ã                  óÈ   € ^ RI Ht ^ RIt^ RIt^ RIHtHtHtHtH	t	 ^ RI
HtHt ^ RIt^ RIHt ]! R4      t]! R4      tR R	 ltR
 R lt ! R R]4      tR R ltR R ltR# )é    )ÚannotationsN)ÚAsyncIteratorÚCallableÚ	CoroutineÚIterableÚIterator)Ú	ParamSpecÚTypeVar)ÚStarletteDeprecationWarningÚPÚTc               ó    € V ^8„  d   QhRRRR/# )é   Úargsztuple[Callable, dict]ÚreturnÚNone© )Úformats   "Úf/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/starlette/concurrency.pyÚ__annotate__r      s   € ÷ Jñ JÐ*?ð JÀDñ Jó    c               ‡  ój  a"  € \         P                  ! R \        4       \        P                  ! 4       ;_uu_4       GRj  x€L
 oR V3R llpV  F,  w  r#SP                  V\        P                  ! V3/ VB 4       K.  	  RRR4      GRj  x€L
  R#  LQ L  + GRj  x€L 
 '       g   i     R# ; i5i)zOrun_until_first_complete is deprecated and will be removed in a future version.Nc               ó    € V ^8„  d   QhRRRR/# )r   ÚfunczCallable[[], Coroutine]r   r   r   )r   s   "r   r   Ú.run_until_first_complete.<locals>.__annotate__   s   € ÷ 	-ñ 	-Ð3ð 	-¸ñ 	-r   c              “  óf   <"  € V ! 4       G R j  x€L
  SP                   P                  4        R #  L 5i©N)Úcancel_scopeÚcancel)r   Ú
task_groups   &€r   ÚrunÚ%run_until_first_complete.<locals>.run   s&   øé € Ù“&�LˆLØ×#Ñ#×*Ñ*Ö,ñ ùs   ƒ1Ž/�!1)ÚwarningsÚwarnr   ÚanyioÚcreate_task_groupÚ
start_soonÚ	functoolsÚpartial)r   r!   r   Úkwargsr    s   *   @r   Úrun_until_first_completer+      sz   øé € Ü‡M‚MØYÜ#ôô
 ×&Ò&×(×(Ô(¨J÷	-ð 	-ó !‰LˆDØ×!Ñ! #¤y×'8Ò'8¸Ñ'HÀÑ'HÖIñ !÷ )×(×(×(×(×(üsM   ƒ=B3Á BÁB3Á<BÂ B3ÂBÂB3ÂB3ÂB0	ÂBÂ
B0	Â(B0	Â*	B3c               ó(   € V ^8„  d   QhRRRRRRRR/# )	r   r   zCallable[P, T]r   zP.argsr*   zP.kwargsr   r   r   )r   s   "r   r   r       s)   € ÷ 0ñ 0 .ð 0¸ð 0È8ð 0ÐXYñ 0r   c              �  ó�   "  € \         P                  ! V .VO5/ VB p \        P                  P	                  V 4      G R j  x€L
 #  L5ir   )r(   r)   r%   Ú	to_threadÚrun_sync)r   r   r*   s   &*,r   Úrun_in_threadpoolr0       s:   é € Ü×Ò˜TÐ3 DÒ3¨FÑ3€DÜ—‘×)Ñ)¨$Ó/×/Ð/Ñ/ùs   ‚=A¿AÁ Ac                  ó   € ] tR t^%tRtR# )Ú_StopIterationr   N)Ú__name__Ú
__module__Ú__qualname__Ú__firstlineno__Ú__static_attributes__r   r   r   r2   r2   %   s   † Ûr   r2   c               ó    € V ^8„  d   QhRRRR/# )r   ÚiteratorzIterator[T]r   r   r   )r   s   "r   r   r   )   s   € ÷ ñ �Kð  Añ r   c                óD   €  \        V 4      #   \         d    \        hi ; ir   )ÚnextÚStopIterationr2   )r9   s   &r   Ú_nextr=   )   s&   € ðÜ�H‹~ÐøÜô ÜÐðús   ‚
 �c               ó    € V ^8„  d   QhRRRR/# )r   r9   zIterable[T]r   zAsyncIterator[T]r   )r   s   "r   r   r   3   s   € ÷ ñ Øðàñr   c               ó®   "  € \        V 4      p  \        P                  P                  \        V4      G Rj  x€L
 5x € K3   L	  \
         d     R# i ; i5i)TN)Úiterr%   r.   r/   r=   r2   )r9   Úas_iterators   & r   Úiterate_in_threadpoolrB   3   sF   é € ô �x“.€KØ
ð	ÜŸ™×0Ñ0´¸ÓD×DÕDÑDøÜô 	Úð	üs7   ‚A�'A ·A¸A ¿AÁA ÁAÁAÁAÁA)Ú
__future__r   r(   r#   Úcollections.abcr   r   r   r   r   Útypingr	   r
   Úanyio.to_threadr%   Ústarlette.exceptionsr   r   r   r+   r0   Ú	Exceptionr2   r=   rB   r   r   r   Ú<module>rI      sP   ðÝ "ã Û ß RÕ Rß %ã å <áˆcƒN€ÙˆCƒL€õJõ 0ô
	�Yô 	õ÷r   