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   úK/var/www/html/CropPilot/venv/lib/python3.10/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

    )r   r	   r   )r    Ú	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.   )Úselfr2   r4   r   r   r   Ú__init__k   s   
zRunvarToken.__init__r   úRunvarToken[T]c                 C  s   | S ©Nr   ©r6   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 r9   )r/   Úreset)r6   r=   r?   rA   r   r   r   Ú__exit__s   s   zRunvarToken.__exit__N)r2   r3   r4   r5   )r   r8   )r=   r>   r?   r@   rA   rB   r   r   )r#   r$   r%   Ú	__slots__r7   r;   rD   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Údefaultr5   c                 C  s   || _ || _d S r9   rF   )r6   rI   rK   r   r   r   r7   ˆ   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 r9   )r	   r"   r)   ÚKeyError)r6   r"   Úrun_varsr   r   r   Ú_current_varsŽ   s   
þzRunVar._current_varsr   úT | Dc                 C  ó   d S r9   r   ©r6   rK   r   r   r   Úget—   r<   z
RunVar.getr   c                 C  rQ   r9   r   r:   r   r   r   rS   š   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)rO   rM   r   r-   rH   ÚLookupErrorrG   rR   r   r   r   rS   �   s   

ÿýÿr4   r8   c                 C  s&   | j }t| | | tj¡ƒ}||| < |S r9   )rO   r   rS   r   r-   )r6   r4   Úcurrent_varsÚtokenr   r   r   Úset¬   s   z
RunVar.setrW   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/   Ú
ValueErrorr1   r0   r*   r-   rO   rM   )r6   rW   r   r   r   rC   ²   s   
ÿ
zRunVar.resetc                 C  s   d| j ›d�S )Nz<RunVar name=ú>)rG   r:   r   r   r   Ú__repr__Ã   s   zRunVar.__repr__N)rI   rJ   rK   r5   )r   rL   )rK   r   r   rP   )r   r   )rK   rT   r   rP   )r4   r   r   r8   )rW   r8   r   r   )r   rJ   )r#   r$   r%   r&   rE   r*   r-   r'   r7   ÚpropertyrO   r   rS   rX   rC   r[   r   r   r   r   r   |   s"   
 ÿÿ

r   )r   r   )r   r   )"Ú
__future__r   Ú__all__r+   Údataclassesr
   Útypesr   Útypingr   r   r   r   r   r   Úweakrefr   Ú_core._eventloopr   Úabcr   r   r   r   r   r   r   r	   r)   r'   ÚEnumr*   r   r   r   r   r   r   Ú<module>   s,    
 




