+
    NV-j&  ã                  ó”  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   "Ú_/Volumes/fast/ai/experiments/ui-tars-smoke/.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ñ 	8 tñ 	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Ô7ùr    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   † Ø—9’9“;„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Ð3ˆH”y Ñ.ØŠ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Ø—}‘}Ò$ñ :ð	%úô Ø˜TŸZ™Z˜LÐ(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Ñ"2°4¼×9LÑ9LÓ"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   € Ø˜tŸz™z™n¨AÐ.Ð.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}   ‡ ñð $€Ià6A×6NÑ6N€LÐ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Ý %å /Ý áˆCƒL€ÙˆCƒL€õ+õ	8õ;ð Ù
�$˜UÔ#÷ð ó $ó ðõ4ñ  @QÓ?R€	Ð<Ó Rô�$—)‘)ô ô�'˜!•*ô ô(H/ˆW�Q�Zö H/r   