+
    Di^                        ^ 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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PTc                    V ^8  d   QhRRRR/# )   argsztuple[Callable, dict]returnNone )formats   "s/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/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&     &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Callable[P, T]r   zP.argsr*   zP.kwargsr   r   r   )r   s   "r   r   r      s)     0 0. 0 08 0XY 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3D3F3D))$////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   1   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   1   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%   r   r   r+   r0   	Exceptionr2   r=   rB   r   r   r   <module>rH      sM    "   R R % cNCLJ 0
	Y 	r   