o
    %=j&  ã                   @  s  U d dl mZ dZd dlZd dlmZ d dlmZ d dlm	Z	m
Z
mZmZmZmZ d dlmZ dd	lmZ dd
lmZ edƒZedƒZd$dd„Zd$dd„Zd$dd„Zeeddd�G dd„ dƒƒƒZd%dd„Zeƒ Zded< G dd„ dejƒZG d d!„ d!e
e ƒZ G d"d#„ d#e
e ƒZ!dS )&é    )Ú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ÚDÚreturnÚNonec                   Ã  ó   �t ƒ  ¡ I dH  dS )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   © r   r   úXC:\Users\psant\Downloads\Anu Raj Backend\school\venv\Lib\site-packages\anyio/lowlevel.pyr      ó   €r   c                   Ã  r   )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   €	r   c                   Ã  r   )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   r   r   TF)ÚfrozenÚreprc                   @  s"   e Zd ZU dZded< ded< dS )r   za
    An opaque object that holds a reference to an event loop.

    .. versionadded:: 4.11.0
    ztype[AsyncBackend]Úbackend_classÚobjectÚnative_tokenN)Ú__name__Ú
__module__Ú__qualname__Ú__doc__Ú__annotations__r   r   r   r   r   D   s   
 r   c                  C  s   t ƒ } |  ¡ }t| |ƒS )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

    N)r   r	   r   )r    Z	raw_tokenr   r   r   r	   Q   s   
r	   z1WeakKeyDictionary[object, dict[RunVar[Any], Any]]Ú	_run_varsc                   @  s   e Zd Ze ¡ ZdS )Ú_NoValueSetN)r#   r$   r%   ÚenumÚautoÚNO_VALUE_SETr   r   r   r   r)   d   s    r)   c                   @  s.   e Zd ZdZddd„Zdd
d„Zddd„ZdS )r   ©Ú_varÚ_valueÚ	_redeemedÚvarú	RunVar[T]Úvalueú%T | Literal[_NoValueSet.NO_VALUE_SET]c                 C  s   || _ || _d| _d S )NFr-   )Úselfr1   r3   r   r   r   Ú__init__k   s   
zRunvarToken.__init__r   úRunvarToken[T]c                 C  s   | S ©Nr   ©r5   r   r   r   Ú	__enter__p   ó   zRunvarToken.__enter__Úexc_typeútype[BaseException] | NoneÚexc_valúBaseException | NoneÚexc_tbúTracebackType | Noner   c                 C  s   | j  | ¡ d S r8   )r.   Úreset)r5   r<   r>   r@   r   r   r   Ú__exit__s   s   zRunvarToken.__exit__N)r1   r2   r3   r4   )r   r7   )r<   r=   r>   r?   r@   rA   r   r   )r#   r$   r%   Ú	__slots__r6   r:   rC   r   r   r   r   r   h   s
    

r   c                   @  sˆ   e Zd ZU dZdZejZded< efd"d	d
„Ze	d#dd„ƒZ
ed$dd„ƒZed%dd„ƒZefd&dd„Zd'dd„Zd(dd„Zd)dd „Zd!S )*r   a  
    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]r,   ÚnameÚstrÚdefaultr4   c                 C  s   || _ || _d S r8   rE   )r5   rH   rJ   r   r   r   r6   ˆ   s   
zRunVar.__init__r   údict[RunVar[T], T]c                 C  s6   t ƒ j}zt| W S  ty   i  }t|< | Y S w r8   )r	   r"   r(   ÚKeyError)r5   r"   Zrun_varsr   r   r   Ú_current_varsŽ   s   
þzRunVar._current_varsr   úT | Dc                 C  ó   d S r8   r   ©r5   rJ   r   r   r   Úget—   r;   z
RunVar.getr   c                 C  rO   r8   r   r9   r   r   r   rQ   š   r;   ú%D | Literal[_NoValueSet.NO_VALUE_SET]c                 C  sZ   z| j |  W S  ty#   |tjur| Y S | jtjur!| j Y S Y nw td| j› d�ƒ‚)NzRun variable "z!" has no value and no default set)rM   rL   r   r,   rG   ÚLookupErrorrF   rP   r   r   r   rQ   �   s   

ÿýÿr3   r7   c                 C  s&   | j }t| | | tj¡ƒ}||| < |S r8   )rM   r   rQ   r   r,   )r5   r3   Zcurrent_varsÚtokenr   r   r   Úset¬   s   z
RunVar.setrT   r   c                 C  sb   |j | ur	tdƒ‚|jrtdƒ‚|jtju r&z| j| = W n ty%   Y nw |j| j| < d|_d S )Nz)This token does not belong to this RunVarz This token has already been usedT)r.   Ú
ValueErrorr0   r/   r)   r,   rM   rL   )r5   rT   r   r   r   rB   ²   s   
ÿ
zRunVar.resetc                 C  s   d| j ›d�S )Nz<RunVar name=ú>)rF   r9   r   r   r   Ú__repr__Ã   s   zRunVar.__repr__N)rH   rI   rJ   r4   )r   rK   )rJ   r   r   rN   )r   r   )rJ   rR   r   rN   )r3   r   r   r7   )rT   r7   r   r   )r   rI   )r#   r$   r%   r&   rD   r)   r,   r'   r6   ÚpropertyrM   r   rQ   rU   rB   rX   r   r   r   r   r   |   s"   
 ÿÿ

r   )r   r   )r   r   )"Ú
__future__r   Ú__all__r*   Údataclassesr
   Útypesr   Útypingr   r   r   r   r   r   Úweakrefr   Z_core._eventloopr   Úabcr   r   r   r   r   r   r   r	   r(   r'   ÚEnumr)   r   r   r   r   r   r   Ú<module>   s,    
 




