+
    Di&                      a  0 t $ ^ RIHt R t^ RIt^ RIHt ^ RIHt ^ RI	H
t
HtHtHtHtHt ^ R	IHt ^R
IHt ^RIHt ]! R4      t]! R4      tR R ltR R ltR R lt]]! RRR7       ! R R4      4       4       tR R lt]! 4       tR]R&    ! R R]P>                  4      t  ! R R]],          4      t! ! R R]],          4      t"R# )!    )annotationsEventLoopTokenRunvarTokenRunVarN)	dataclass)TracebackType)AnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend)AsyncBackendTDc                   V ^8  d   QhRR/#    returnNone )formats   "l/Users/tonyclaw/.openclaw/workspace/services/omi-webhook/venv/lib/python3.14/site-packages/anyio/lowlevel.py__annotate__r      s     + +$ +    c                 R   "   \        4       P                  4       G Rj  xL
  R#  L5i)z
Check for cancellation and allow the scheduler to switch to another task.

Equivalent to (but more efficient than)::

    await checkpoint_if_cancelled()
    await cancel_shielded_checkpoint()

.. versionadded:: 3.0

N)r   
checkpointr   r   r   r   r      s      

(
(
***   '%'c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   )   s     	8 	8t 	8r   c                 R   "   \        4       P                  4       G Rj  xL
  R#  L5i)z
Enter a checkpoint if the enclosing cancel scope has been cancelled.

This does not allow the scheduler to switch to a different task.

.. versionadded:: 3.0

N)r   checkpoint_if_cancelledr   r   r   r#   r#   )   s      

5
5
777r    c                   V ^8  d   QhRR/# r   r   )r   s   "r   r   r   5   s     ; ;$ ;r   c                 R   "   \        4       P                  4       G Rj  xL
  R#  L5i)z
Allow the scheduler to switch to another task but without checking for cancellation.

Equivalent to (but potentially more efficient than)::

    with CancelScope(shield=True):
        await checkpoint()

.. versionadded:: 3.0

N)r   cancel_shielded_checkpointr   r   r   r&   r&   5   s      

8
8
:::r    TF)frozenreprc                  0    ] tR t^Dt$ RtR]R&   R]R&   RtR# )r   zU
An opaque object that holds a reference to an event loop.

.. versionadded:: 4.11.0
ztype[AsyncBackend]backend_classobjectnative_tokenr   N)__name__
__module____qualname____firstlineno____doc____annotations____static_attributes__r   r   r   r   r   D   s     &%r   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   r   Q   s     4 4~ 4r   c                 L    \        4       p V P                  4       p\        W4      # )z
Return a token object that can be used to call code in the current event loop from
another thread.

:raises NoEventLoopError: if no supported asynchronous event loop is running in the
    current thread

.. versionadded:: 4.11.0

)r   current_tokenr   )r*   	raw_tokens     r   r6   r6   Q   s%     &'M++-I-33r   z1WeakKeyDictionary[object, dict[RunVar[Any], Any]]	_run_varsc                  8    ] tR t^dt]P
                  ! 4       tRtR# )_NoValueSetr   N)r-   r.   r/   r0   enumautoNO_VALUE_SETr3   r   r   r   r:   r:   d   s    99;Lr   r:   c                  >    ] tR t^htR	tR R ltR R ltR R ltRtR# )
r   c                    V ^8  d   QhRRRR/# )r   varz	RunVar[T]value%T | Literal[_NoValueSet.NO_VALUE_SET]r   )r   s   "r   r   RunvarToken.__annotate__k   s      I .S r   c                	,    Wn         W n        R V n        R# )FN_var_value	_redeemed)selfr@   rA   s   &&&r   __init__RunvarToken.__init__k   s    	=Br   c                   V ^8  d   QhRR/# )r   r   RunvarToken[T]r   )r   s   "r   r   rC   p   s      > r   c                	    V # Nr   rI   s   &r   	__enter__RunvarToken.__enter__p   s    r   c               (    V ^8  d   QhRRRRRRRR/# )	r   exc_typeztype[BaseException] | Noneexc_valzBaseException | Noneexc_tbzTracebackType | Noner   r   r   )r   s   "r   r   rC   s   s2      , & %	
 
r   c                	<    V P                   P                  V 4       R # rO   )rF   reset)rI   rT   rU   rV   s   &&&&r   __exit__RunvarToken.__exit__s   s     			r   )rH   rG   rF   NrE   )	r-   r.   r/   r0   	__slots__rJ   rQ   rY   r3   r   r   r   r   r   h   s    -I
 r   c                      ] tR t^|t$ RtRt]P                  tR]R&   ]3R R llt	]
R R l4       t]R R	 l4       t]R
 R l4       t]3R R lltR R ltR R ltR R ltRtR# )r   z
Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop.

Can be used as a context manager, Just like :class:`~contextvars.ContextVar`, that
will reset the variable to its previous value when the context block is exited.
z!Literal[_NoValueSet.NO_VALUE_SET]r=   c                    V ^8  d   QhRRRR/# )r   namestrdefaultrB   r   )r   s   "r   r   RunVar.__annotate__   s         "G r   c                	    Wn         W n        R # rO   _name_default)rI   r^   r`   s   &&&r   rJ   RunVar.__init__   s     
r   c                   V ^8  d   QhRR/# )r   r   zdict[RunVar[T], T]r   )r   s   "r   r   ra      s      1 r   c                	    \        4       P                  p \        V,          #   \         d    / ;p\        T&   Tu # i ; irO   )r6   r,   r8   KeyError)rI   r,   run_varss   &  r   _current_varsRunVar._current_vars   sB    $33	\** 	133Hy.O	s   # >>c                    V ^8  d   QhRRRR/# )r   r`   r   r   T | Dr   )r   s   "r   r   ra      s    ++1++r   c                	    R # rO   r   rI   r`   s   &&r   get
RunVar.get   s    (+r   c                   V ^8  d   QhRR/# )r   r   r   r   )r   s   "r   r   ra      s    Qr   c                	    R # rO   r   rP   s   &r   rq   rr      s    r   c                    V ^8  d   QhRRRR/# )r   r`   z%D | Literal[_NoValueSet.NO_VALUE_SET]r   rn   r   )r   s   "r   r   ra      s     
 
<
	
r   c                	    V P                   V ,          #   \         dH    T\        P                  Jd   Tu # T P                  \        P                  Jd   T P                  u #  Mi ; i\        R T P                   R24      h)zRun variable "z!" has no value and no default set)rk   ri   r   r=   re   LookupErrorrd   rp   s   &&r   rq   rr      s{    	%%%d++ 	%f111f&9&99}}$ :	% TZZL(IJ
 	
s    !A'*A'&A'c                    V ^8  d   QhRRRR/# )r   rA   r   r   rM   r   )r   s   "r   r   ra      s       ~ r   c                	x    V P                   p\        WP                  V \        P                  4      4      pWV &   V# rO   )rk   r   rq   r   r=   )rI   rA   current_varstokens   &&  r   set
RunVar.set   s7    ))D"2"249L9L"MN"Tr   c                    V ^8  d   QhRRRR/# )r   r{   rM   r   r   r   )r   s   "r   r   ra      s      > d r   c                	2   VP                   V Jd   \        R 4      hVP                  '       d   \        R4      hVP                  \        P
                  J d    V P                  V  MVP                  V P                  V &   RVn        R#   \         d     Li ; i)z)This token does not belong to this RunVarz This token has already been usedTN)rF   
ValueErrorrH   rG   r:   r=   rk   ri   )rI   r{   s   &&r   rX   RunVar.reset   s    ::T!HII????@@<<;333&&t, (-||Dt$  s   B BBc                   V ^8  d   QhRR/# )r   r   r_   r   )r   s   "r   r   ra      s     / /# /r   c                	$    R V P                   : R2# )z<RunVar name=>)rd   rP   s   &r   __repr__RunVar.__repr__   s    tzznA..r   )re   rd   Nrc   )r-   r.   r/   r0   r1   r[   r:   r=   r2   rJ   propertyrk   r   rq   r|   rX   r   r3   r   r   r   r   r   |   s}     $I6A6N6NL3N KW    + +  @L
"/ /r   )r   r   r   r   r#   r&   r6   )#__conditional_annotations__
__future__r   __all__r;   dataclassesr   typesr   typingr	   r
   r   r   r   r   weakrefr   _core._eventloopr   abcr   r   r   r   r#   r&   r   r6   r8   r2   Enumr:   r   r   )r   s   @r   <module>r      s    " "  !  B B % / CLCL+	8; 
$U#  $ 4  @Q?R	< R$)) '!* (H/WQZ H/r   