← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/anyio/__pycache__/lowlevel.cpython-312.pyc
115 lines
�
c�bj� � �t � U d dl mZ dZd dlZd dlmZ d dlmZ d dlm Z m
Z
m Z m Z m
Z
mZmZ d dlmZ dd lmZ e rdd
lmZ e
d � Z e
d � Zd d
�Zd d�Zd d�Ze edd�� G d� d� � � Zd d�Z e� Z de d< G d� dej> � Z G d� de e � Z! G d � d e e � Z"y) � )� annotations)�EventLoopToken� RunvarToken�RunVar�
checkpoint�checkpoint_if_cancelled�cancel_shielded_checkpoint�
current_tokenN)� dataclass)�
TracebackType)�
TYPE_CHECKING�Any�Generic�Literal�TypeVar�final�overload)�WeakKeyDictionary� )�get_async_backend)� AsyncBackend�T�Dc � �P K � t � j � � d{ ��� y7 ��w)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 � � �e/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/anyio/lowlevel.pyr r s � �� � �
�
(�
(�
*�*�*�� � &�$�&c � �P K � t � j � � d{ ��� y7 ��w)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 K � t � j � � d{ ��� y7 ��w)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 7 s � �� � �
�
8�
8�
:�:�:�r TF)�frozen�reprc �& � e Zd ZU dZded< ded< y)r za
An opaque object that holds a reference to an event loop.
.. versionadded:: 4.11.0
ztype[AsyncBackend]�
backend_class�object� native_tokenN)�__name__�
__module__� __qualname__�__doc__�__annotations__r r r r r F s � �� &�%��r r c �N � t � } | j � }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_tokens r r
r
S s' � � &�'�M� �+�+�-�I� �-�� 3�3r z1WeakKeyDictionary[object, dict[RunVar[Any], Any]]� _run_varsc �. � e Zd Z ej � Zy)� _NoValueSetN)r' r( r) �enum�auto� NO_VALUE_SETr r r r0 r0 f s � � �4�9�9�;�Lr r0 c �< � e Zd ZdZdZdd�Zdd�Z d d�Zy)
r z�
A token that can be used to restore a :class:`RunVar` to its previous value.
Returned by :meth:`RunVar.set`. Can be used as a context manager to automatically
reset the variable on exit, or passed directly to :meth:`RunVar.reset`.
��_var�_value� _redeemedc �. � || _ || _ d| _ y )NFr5 )�self�var�values r �__init__zRunvarToken.__init__t s � ��� �=B�� � ��r c � � | S �Nr �r: s r � __enter__zRunvarToken.__enter__y s � �� r c �: � | j j | � y r? )r6 �reset)r: �exc_type�exc_val�exc_tbs r �__exit__zRunvarToken.__exit__| s � �
� � ���� r N)r; z RunVar[T]r< �%T | Literal[_NoValueSet.NO_VALUE_SET])�return�RunvarToken[T])rD ztype[BaseException] | NonerE zBaseException | NonerF zTracebackType | NonerI �None)r' r( r) r* � __slots__r= rA rG r r r r r j sC � �� .�I� �
� �,� � &� � %� �
� r r c � � e Zd ZU dZdZej Zded< ef dd�Ze dd�� Z
e dd�� Z e dd�� Z ef dd �Z dd
�Z
dd �Zdd �Zy
)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]r3 c � � || _ || _ y r? rN )r: �name�defaults r r= zRunVar.__init__� s � � ��
� ��
r c �v � t � j } t | S # t $ r i x}t |< |cY S w xY wr? )r
r& r. �KeyError)r: r& �run_varss r �
_current_varszRunVar._current_vars� sB � �$��3�3� � � �\�*� *��� �13� 3�H�y� �.��O� �s � �8�8c � � y r? r �r: rS s r �getz
RunVar.get� s � �(+r c � � y r? r r@ s r rZ z
RunVar.get� s � �r c �� � | j | S # t $ rC |t j ur|cY S | j t j ur| j cY S Y nw xY wt d| j � d�� �)a2
Return the current value of this run variable.
:param default: a fallback value to return if no value has been set
:return: the current value, the provided default, or the variable's own default
:raises LookupError: if no value is set and no default is available
zRun variable "z!" has no value and no default set)rW rU r r3 rP � LookupErrorrO rY s r rZ z
RunVar.get� s{ � � %��%�%�d�+� +��� %��f� 1� 1�1� ��� � �f�&9�&9�9��}�}�$� :� %�� � �T�Z�Z�L�(I� J�
�
s � � A �(A � A c �| � | j }t | |j | t j � � }||| < |S )z�
Set the value of this run variable for the current event loop.
:param value: the new value
:return: a token that can be used to restore the previous value
)rW r rZ r r3 )r: r< � current_vars�tokens r �setz
RunVar.set� s= � � �)�)� ��D�,�"2�"2�4��9L�9L�"M�N�� "� �T��� r c �4 � |j | ur t d� �|j r t d� �|j t j
u r | j | = d|_ y|j | j | < d|_ y# t $ r
Y d|_ yw xY w)a
Restore this run variable to the value it held before the matching :meth:`set`.
:param token: the token returned by :meth:`set`
:raises ValueError: if the token belongs to a different :class:`RunVar` or the token
has already been used
z)This token does not belong to this RunVarz This token has already been usedTN)r6 �
ValueErrorr8 r7 r0 r3 rW rU )r: r` s r rC z RunVar.reset� s� � � �:�:�T� !� � H�I� I� �?�?� � ?�@� @� �<�<�;�3�3� 3�
��&�&�t�,� ��� (-�|�|�D� � �t� $� ���� �
�� ���
�s �
B � B�Bc �" � d| j �d�S )Nz
<RunVar name=�>)rO r@ s r �__repr__zRunVar.__repr__� s � � �t�z�z�n�A�.�.r N)rR �strrS rH )rI zdict[RunVar[T], T])rS r rI �T | D)rI r )rS z%D | Literal[_NoValueSet.NO_VALUE_SET]rI rh )r< r rI rJ )r` rJ rI rK )rI rg )r' r( r) r* rL r0 r3 r+ r= �propertyrW r rZ ra rC rf r r r r r � s� � �� $�I�6A�6N�6N�L�3�N� KW� �� �"G� � � � � � �+� �+�
�� �� @L�
�<�
� �
�. � �2/r r )rI rK )rI r )#�
__future__r �__all__r1 � dataclassesr �typesr �typingr
r r r r r r �weakrefr �_core._eventloopr �abcr r r r r r r r
r. r+ �Enumr0 r r r r r �<module>rs s� �� "� �� � !� � Q� Q� Q� %� /��!� �C�L�� �C�L�� +� 8� ;� �
�$�U�#�� � $� ��
4� @Q�?R� � <� R� �$�)�)� � �'�!�*� �6_/�W�Q�Z� _/r