ó
    Eñi&  ã                  ón  • % S SK Jr  SrS SKrS SKJr  S SKJr  S SKJ	r	J
r
JrJrJrJr  S SKJr  SS	KJr  SS
KJr  \" S5      r\" S5      rSS jrSS jrSS jr\\" SSS9 " S S5      5       5       rSS jr\" 5       rS\S'    " S S\R<                  5      r " S S\
\   5      r  " S S\
\   5      r!g) é    )Úannotations)ÚEventLoopTokenÚRunvarTokenÚRunVarÚ
checkpointÚcheckpoint_if_cancelledÚcancel_shielded_checkpointÚcurrent_tokenN)Ú	dataclass)ÚTracebackType)ÚAnyÚGenericÚLiteralÚTypeVarÚfinalÚoverload)ÚWeakKeyDictionaryé   )Úget_async_backend)ÚAsyncBackendÚTÚDc               ƒ  óP   #   • [        5       R                  5       I Sh  v•N   g N7f)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   r   © ó    ÚK/home/mande/repo/quber/.venv/lib/python3.13/site-packages/anyio/lowlevel.pyr   r      s   é € ô Ó
×
(Ñ
(Ó
*×*Ó*ùó   ‚&ž$Ÿ&c               ƒ  óP   #   • [        5       R                  5       I Sh  v•N   g N7f)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   r   r   r   r   r   r   )   s   é € ô Ó
×
5Ñ
5Ó
7×7Ó7ùr   c               ƒ  óP   #   • [        5       R                  5       I Sh  v•N   g N7f)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   r	   r   r   r   r	   r	   5   s   é € ô Ó
×
8Ñ
8Ó
:×:Ó:ùr   TF)ÚfrozenÚreprc                  ó.   • \ rS rSr% SrS\S'   S\S'   Srg)	r   éD   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   r   c                 óL   • [        5       n U R                  5       n[        X5      $ )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   r
   r   )r$   Ú	raw_tokens     r   r
   r
   Q   s%   € ô &Ó'€MØ×+Ñ+Ó-€IÜ˜-Ó3Ð3r   z1WeakKeyDictionary[object, dict[RunVar[Any], Any]]Ú	_run_varsc                  ó6   • \ rS rSr\R
                  " 5       rSrg)Ú_NoValueSetéd   r   N)r'   r(   r)   r*   ÚenumÚautoÚNO_VALUE_SETr-   r   r   r   r2   r2   d   s   † Ø—9’9“;ƒLr   r2   c                  óF   • \ rS rSrSrSS jrS	S jr        S
S jrSrg)r   éh   ©Ú_varÚ_valueÚ	_redeemedc                ó*   • Xl         X l        SU l        g )NFr9   )ÚselfÚvarÚvalues      r   Ú__init__ÚRunvarToken.__init__k   s   € ØŒ	Ø=BŒØˆ�r   c                ó   • U $ ©Nr   ©r>   s    r   Ú	__enter__ÚRunvarToken.__enter__p   s   € Øˆr   c                ó:   • U R                   R                  U 5        g rD   )r:   Úreset)r>   Úexc_typeÚexc_valÚexc_tbs       r   Ú__exit__ÚRunvarToken.__exit__s   s   € ð 	�	‰	�‰˜Õr   )r<   r;   r:   N)r?   z	RunVar[T]r@   ú%T | Literal[_NoValueSet.NO_VALUE_SET])ÚreturnúRunvarToken[T])rJ   ztype[BaseException] | NonerK   zBaseException | NonerL   zTracebackType | NonerP   ÚNone)	r'   r(   r)   r*   Ú	__slots__rA   rF   rM   r-   r   r   r   r   r   h   s<   † Ø-€Iôô
ðà,ðð &ðð %ð	ð
 
÷r   r   c                  óÆ   • \ rS rSr% SrSr\R                  rS\S'   \4   SS jjr	\
SS j5       r\SS j5       r\SS	 j5       r\4   SS
 jjrSS jrSS jrSS jrSrg)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.
©Ú_nameÚ_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r6   c                ó   • Xl         X l        g rD   rV   )r>   ÚnameÚdefaults      r   rA   ÚRunVar.__init__ˆ   s   € ð Œ
Ø�r   c                óx   • [        5       R                  n [        U   $ ! [         a    0 =n[        U'   Us $ f = frD   )r
   r&   r0   ÚKeyError)r>   r&   Úrun_varss      r   Ú_current_varsÚRunVar._current_varsŽ   sB   € ä$“×3Ñ3ˆð	Ü˜\Ñ*Ð*øÜó 	Ø13Ð3ˆH”y Ñ.ØŠOð	ús   – Ÿ9¸9c                ó   • g rD   r   ©r>   r[   s     r   ÚgetÚ
RunVar.get—   s   € Ø(+r   c                ó   • g rD   r   rE   s    r   rd   re   š   s   € Ør   c                óø   •  U R                   U    $ ! [         aE    U[        R                  La  Us $ U R                  [        R                  La  U R                  s $  Of = f[        SU R                   S35      e)NzRun variable "z!" has no value and no default set)r`   r^   r   r6   rX   ÚLookupErrorrW   rc   s     r   rd   re   �   s{   € ð	%Ø×%Ñ% dÑ+Ð+øÜó 	%Øœf×1Ñ1Ò1Ø’Ø—‘¤f×&9Ñ&9Ò9Ø—}‘}Ò$ñ :ð	%úô Ø˜TŸZ™Z˜LÐ(IÐJó
ð 	
s   ‚ ‘A ²)A ÁA c                óx   • U R                   n[        XR                  U [        R                  5      5      nXU '   U$ rD   )r`   r   rd   r   r6   )r>   r@   Úcurrent_varsÚtokens       r   ÚsetÚ
RunVar.set¬   s7   € Ø×)Ñ)ˆÜ˜D×"2Ñ"2°4¼×9LÑ9LÓ"MÓNˆØ"�TÑØˆr   c                ó(  • UR                   U La  [        S5      eUR                  (       a  [        S5      eUR                  [        R
                  L a   U R                  U 	 OUR                  U R                  U '   SUl        g ! [         a     Nf = f)Nz)This token does not belong to this RunVarz This token has already been usedT)r:   Ú
ValueErrorr<   r;   r2   r6   r`   r^   )r>   rk   s     r   rI   ÚRunVar.reset²   sƒ   € Ø�:‰:˜TÒ!ÜÐHÓIÐIà�?�?ÜÐ?Ó@Ð@à�<‰<œ;×3Ñ3Ò3ðØ×&Ñ& tÑ,ð (-§|¡|ˆD×Ñ˜tÑ$àˆ�øô ó Ùðús   ÁB Â
BÂBc                ó$   • SU R                   < S3$ )Nz<RunVar name=Ú>)rW   rE   s    r   Ú__repr__ÚRunVar.__repr__Ã   s   € Ø˜tŸz™z™n¨AÐ.Ð.r   )rX   rW   N)rZ   Ústrr[   rO   )rP   zdict[RunVar[T], T])r[   r   rP   úT | D)rP   r   )r[   z%D | Literal[_NoValueSet.NO_VALUE_SET]rP   rv   )r@   r   rP   rQ   )rk   rQ   rP   rR   )rP   ru   )r'   r(   r)   r*   r+   rS   r2   r6   r,   rA   Úpropertyr`   r   rd   rl   rI   rs   r-   r   r   r   r   r   |   s˜   ‡ ñð $€Ià6A×6NÑ6N€LÐ3ÓNð KWð Øð Ø"Gõ ð óó ðð Û+ó Ø+àÛó Øð @Lð
Ø<ð
à	õ
ôô÷"/r   r   )rP   rR   )rP   r   )"Ú
__future__r   Ú__all__r4   Údataclassesr   Útypesr   Útypingr   r   r   r   r   r   Úweakrefr   Ú_core._eventloopr   Úabcr   r   r   r   r   r	   r   r
   r0   r,   ÚEnumr2   r   r   r   r   r   Ú<module>r�      s»   ðÞ "ð€ó Ý !Ý ß B× BÝ %å /Ý áˆCƒL€ÙˆCƒL€ô+ô	8ô;ð Ù
�$˜UÑ#÷ð ó $ó ðô4ñ  @QÓ?R€	Ð<Ó Rô�$—)‘)ô ô�'˜!‘*ô ô(H/ˆW�Q‰Zõ H/r   