← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/anyio/streams/__pycache__/file.cpython-312.pyc
73 lines
�
c�bj� � �� � d dl mZ dZd dlmZmZ d dlmZmZ d dl m
Z
d dl m Z d dl
mZmZ dd lmZmZmZmZmZmZ dd
lmZmZ G d � d e� Z G d
� d� Z G d� dee� Z G d� dee� Z y)� )� annotations)�FileReadStream�FileStreamAttribute�FileWriteStream)�Callable�Mapping)�SEEK_SET�UnsupportedOperation)�PathLike)�Path)�IO�Any� )�BrokenResourceError�ClosedResourceError� EndOfStream�TypedAttributeSet� to_thread�typed_attribute)�ByteReceiveStream�ByteSendStreamc �V � e Zd ZU e� Zded< e� Zded< e� Zded< y)r � IO[bytes]�filer �path�int�filenoN)�__name__�
__module__� __qualname__r r �__annotations__r r � � �i/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/anyio/streams/file.pyr r s) � �%�'�D�)�'� �"�D�$�"�!�#�F�C�#r# r c �. � e Zd Zdd�Zdd�Zedd�� Zy)�_BaseFileStreamc � � || _ y �N��_file)�selfr s r$ �__init__z_BaseFileStream.__init__$ s � ���
r# c � �r K � t j | j j � � d { ��� y 7 ��wr( )r �run_syncr* �close�r+ s r$ �aclosez_BaseFileStream.aclose' s$ � �� �� � ����!1�!1�2�2�2�s �-7�5�7c � � � t j � fd�i}t � j d� r� fd�|t j < � j j � � fd�|t j
< |S # t $ r Y |S w xY w)Nc � �� � j S r( r) r0 s �r$ �<lambda>z2_BaseFileStream.extra_attributes.<locals>.<lambda>- s �� �d�j�jr# �namec �B �� t � j j � S r( )r r* r5 r0 s �r$ r4 z2_BaseFileStream.extra_attributes.<locals>.<lambda>1 s �� �4��
�
���;Pr# c �8 �� � j j � S r( )r* r r0 s �r$ r4 z2_BaseFileStream.extra_attributes.<locals>.<lambda>8 s �� �T�Z�Z�=N�=N�=Pr# )r r �hasattrr* r r r
)r+ �
attributess ` r$ �extra_attributesz _BaseFileStream.extra_attributes* s� �� �
� $� $�&8�4
�
� �4�:�:�v� &�3P�J�*�/�/� 0� Q� �J�J� � � � 6Q�J�*�1�1� 2���� $� � � �� �s �A6 �6 B�BN)r r )�return�None)r; z Mapping[Any, Callable[[], Any]])r r r r, r1 �propertyr: r" r# r$ r& r& # s � ��3� �� �r# r& c �@ � e Zd ZdZedd�� Zdd d�Zefd
d�Zd d�Z y) r z�
A byte stream that reads from a file in the file system.
:param file: a file that has been opened for reading in binary mode
.. versionadded:: 3.0
c � � K � t j t |� j d� � d{ ��� } | |� S 7 � �w)z{
Create a file read stream by opening the given file.
:param path: path of the file to read from
�rbN�r r. r �open)�clsr r s r$ � from_pathzFileReadStream.from_pathF s4 � �� � �'�'��T�
����>�>���4�y�� ?�s �->�<�
>c � �� K � |dk r t d� � t j | j j |� � d { ��� }|r|S t �7 �# t $ r t
d �t $ r }t |�d }~ww xY w�w)N� z$max_bytes must be a positive integer) �
ValueErrorr r. r* �readr �OSErrorr r )r+ � max_bytes�data�excs r$ �receivezFileReadStream.receiveQ sx � �� � �q�=� � C�D� D� /�"�+�+�D�J�J�O�O�Y�G�G�D� ��K� � � H��� 0�%�4� /�� /�%�3� .�� /�s: �A9�-A �A�A �
A9�A �A6�*A1�1A6�6A9c � �t K � t j | j j ||� � d{ ��� S 7 ��w)au
Seek the file to the given position.
.. seealso:: :meth:`io.IOBase.seek`
.. note:: Not all file descriptors are seekable.
:param position: position to seek the file to
:param whence: controls how ``position`` is interpreted
:return: the new absolute position
:raises OSError: if the file is not seekable
N)r r. r* �seek)r+ �position�whences r$ rO zFileReadStream.seeka s+ � �� � �'�'��
�
����6�J�J�J�J�s �/8�6�8c � �p K � t j | j j � � d{ ��� S 7 ��w)z�
Return the current stream position.
.. note:: Not all file descriptors are seekable.
:return: the current absolute position
:raises OSError: if the file is not seekable
N)r r. r* �tellr0 s r$ rS zFileReadStream.tellq s' � �� � �'�'��
�
���8�8�8�8�s �-6�4�6N)r �str | PathLike[str]r; r )i )rJ r r; �bytes)rP r rQ r r; r )r; r )
r r r �__doc__� classmethodrD rM r rO rS r" r# r$ r r = s0 � �� �� �� � 7?� K�
9r# r c �8 � e Zd ZdZe d dd�� Zdd�Zy)r z�
A byte stream that writes to a file in the file system.
:param file: a file that has been opened for writing in binary mode
.. versionadded:: 3.0
c � � K � |rdnd}t j t |� j |� � d{ ��� } | |� S 7 � �w)a
Create a file write stream by opening the given file for writing.
:param path: path of the file to write to
:param append: if ``True``, open the file for appending; if ``False``, any
existing file at the given path will be truncated
�ab�wbNrA )rC r �append�moder s r$ rD zFileWriteStream.from_path� s= � �� � �t�4�� �'�'��T�
����>�>���4�y�� ?�s �3A�A�
Ac � �� K � t j | j j |� � d { ��� y 7 �# t $ r t
d �t $ r }t |�d }~ww xY w�wr( )r r. r* �writerG r rI r )r+ �itemrL s r$ �sendzFileWriteStream.send� sR � �� � /��$�$�T�Z�Z�%5�%5�t�<� <� <��� 0�%�4� /�� /�%�3� .�� /�s1 �A �-9 �7�9 �A �9 �A �A�A � A N)F)r rT r\ �boolr; r )r` rU r; r< )r r r rV rW rD ra r" r# r$ r r ~ s; � �� �7<�
�&�
�04�
� �
� �
� /r# r N) �
__future__r �__all__�collections.abcr r �ior r
�osr �pathlibr �typingr
r � r r r r r r �abcr r r r& r r r" r# r$ �<module>rl sd �� "� �� .� -� � � �� � 4�$�+� $�� �4>9�_�&7� >9�B /�o�~� /r#