+
    Pj:                        ^ RI Ht ^ RIt^ RIt^ RIt^ RIt^ RIt]P                  R8  d   ^ RIH	t	 M^ RI
H	t	 ]	! R4      t]P                  ! 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)	ParamSpecPTc                    V ^8  d   QhRRRR/# )   argsztuple[typing.Callable, dict]returnNone )formats   "n/Users/ahmed/devFolder/Ultron/claude-voice/gateway/.venv/lib/python3.14/site-packages/starlette/concurrency.py__annotate__r      s     J J*F J4 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%typing.Callable[[], typing.Coroutine]r
   r   r   )r   s   "r   r   .run_until_first_complete.<locals>.__annotate__   s     	- 	-A 	-d 	-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&     &LL##**, s   1/!1)warningswarnDeprecationWarninganyiocreate_task_group
start_soon	functoolspartial)r	   r   r   kwargsr   s   *   @r   run_until_first_completer%      sz     MMY
 &&(((J	- 	- !LD!!#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typing.Callable[P, T]r	   zP.argsr$   zP.kwargsr
   r   r   )r   s   "r   r   r   #   s+     7 7"7 7 7RZ 7_` 7r   c                   "   V'       d   \         P                  ! V 3/ VB p \        P                  P                  ! V .VO5!  G R j  xL
 #  L5i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Ac                      ] tR t^*tRtR# )_StopIterationr   N)__name__
__module____qualname____firstlineno____static_attributes__r   r   r   r,   r,   *   s    r   r,   c                    V ^8  d   QhRRRR/# )r   iteratorztyping.Iterator[T]r
   r   r   )r   s   "r   r   r   .   s      & 1 r   c                D     \        V 4      #   \         d    \        hi ; ir   )nextStopIterationr,   )r3   s   &r   _nextr7   .   s&    H~ s   
 c                    V ^8  d   QhRRRR/# )r   r3   ztyping.Iterable[T]r
   ztyping.AsyncIterator[T]r   )r   s   "r   r   r   8   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)   r7   r,   )r3   as_iterators   & r   iterate_in_threadpoolr<   8   sF      x.K
	00DDDD 		s7   A'A AA AA AAAA)   
   )
__future__r   r"   systypingr   anyio.to_threadr   version_infor   typing_extensionsr   TypeVarr   r%   r*   	Exceptionr,   r7   r<   r   r   r   <module>rG      sc    "  
   w +cN
NN3J 7	Y 	r   