codekingpro/portable-devtools
114k
1�
2 �jL � �� � S SK Jr SrS SKJrJr S SKJrJr S SK J3r4 S SK J r S SK
JrJr SS KJrJrJrJrJrJr SS5KJrJr " S S \5 r " S
S5 r " S S\\5 r " S S\\5 r g)� )� annotations)�FileReadStream�FileStreamAttribute�FileWriteStream)�Callable�Mapping)�SEEK_SET�UnsupportedOperation)�PathLike)�Path)�IO�Any� )�BrokenResourceError�ClosedResourceError� EndOfStream�TypedAttributeSet� to_thread�typed_attribute)�ByteReceiveStream�ByteSendStreamc �^ � \ rS rSr% \" 5 rS\S' \" 5 rS\S' \" 5 rS\S' Sr g )6r � � IO[bytes]�filer �path�int�fileno� N)7�__name__�8__module__� __qualname__�__firstlineno__r r �__annotations__r r �__static_attributes__r � �XD:\code\apps\devtools\python\user_packages\Python313\site-packages\anyio/streams/file.pyr r s) � �%�'�D�)�'� �"�D�$�"�!�#�F�C�#r& r c �< � \ rS rSrSS jrSS jr\S S j5 rSrg)9�_BaseFileStream�# c � � Xl g �N��_file)�selfr s r' �__init__�_BaseFileStream.__init__$ s � ��10r& c � �t # � [ R " U R R 5 I S h v�N g N7fr, )r �run_syncr. �close�r/ s r' �aclose�_BaseFileStream.aclose' s# � � �� � ����!1�!1�2�2�2�s �.8�6�8c � ^ � [ R U 4S j0n[ T R S5 ( a U 4S jU[ R ' T R R 5 U 4S jU[ R11 ' U$ ! [ a U$ f = f)Nc � >� T R $ r, r- r5 s �r' �<lambda>�2_BaseFileStream.extra_attributes.<locals>.<lambda>- s �� �d�j�jr& �namec �B >� [ T R R 5 $ r, )r r. r< r5 s �r' r: r; 1 s �� �4��12�13���;Pr& c �8 >� T R R 5 $ r, )r. r r5 s �r' r: r; 8 s �� �T�Z�Z�=N�=N�=Pr& )r r �hasattrr. r r r14 )r/ �15attributess ` r' �extra_attributes� _BaseFileStream.extra_attributes* s� �� �
� $� $�&8�416�17� �4�:�:�v� &� &�3P�J�*�/�/� 0� Q� �J�J� � � � 6Q�J�*�1�1� 2���� $� � � �� �s � A> �>18B � B r- N)r r )�return�None)rC z Mapping[Any, Callable[[], Any]]) r r! r" r# r0 r6 �propertyrA r% r r& r' r) r) # s � ��3� �� �r& r) c �T � \ rS rSrSr\S S j5 rS19S S jjr\4S S jjr S
S jr20Sr g)r �= z�21A byte stream that reads from a file in the file system.22 23:param file: a file that has been opened for reading in binary mode24 25.. versionadded:: 3.026c � � # � [ R " [ U5 R S5 I Sh v�N nU " U5 $ N 7f)zc27Create a file read stream by opening the given file.28 29:param path: path of the file to read from30 31�rbN�r r3 r �open)�clsr r s r' � from_path�FileReadStream.from_pathF s3 � � � �'�'��T�32����>�>���4�y�� ?�s �.?�=�
?c � �� # � [ R " U R R U5 I S h v�N nU( a U$ [ e N! [ a [33 S e[ a n[ UeS nAff = f7fr, ) r r3 r. �read�34ValueErrorr �OSErrorr r )r/ � max_bytes�data�excs r' �receive�FileReadStream.receiveQ sd � � � /�"�+�+�D�J�J�O�O�Y�G�G�D� ��K� � � H��� 0�%�4� /�� /�%�3� .�� /�s7 �A1�.A �A�A �A1�A �A.�"A)�)A.�.A1c � �t # � [ R " U R R X5 I Sh v�N $ N7f)a5 35Seek the file to the given position.36 37.. seealso:: :meth:`io.IOBase.seek`38 39.. note:: Not all file descriptors are seekable.40 41:param position: position to seek the file to42:param whence: controls how ``position`` is interpreted43:return: the new absolute position44:raises OSError: if the file is not seekable45 46N)r r3 r. �seek)r/ �position�whences r' rY �FileReadStream.seek^ s( � � � �'�'��47�48����J�J�J�J�s �/8�6�8c � �r # � [ R " U R R 5 I Sh v�N $ N7f)z�49Return the current stream position.50 51.. note:: Not all file descriptors are seekable.52 53:return: the current absolute position54:raises OSError: if the file is not seekable55 56N)r r3 r. �tellr5 s r' r^ �FileReadStream.telln s& � � � �'�'��57�58���8�8�8�8�s �.7�5�7r N)r �str | PathLike[str]rC r )i )rS r rC �bytes)rZ r r[ r rC r )rC r ) r r! r" r# �__doc__� classmethodrM rV r rY r^ r% r r& r' r r = s0 � �� �� �� � 7?� K� 599r& r c �F � \ rS rSrSr\ S SS jj5 rS S jrSrg)60r �{ z�61A byte stream that writes to a file in the file system.62 63:param file: a file that has been opened for writing in binary mode64 65.. versionadded:: 3.066c � � # � U( a SOSn[ R " [ U5 R U5 I Sh v�N nU " U5 $ N 7f)z�67Create a file write stream by opening the given file for writing.68 69:param path: path of the file to write to70:param append: if ``True``, open the file for appending; if ``False``, any71 existing file at the given path will be truncated72 73�ab�wbNrJ )rL r �append�moder s r' rM �FileWriteStream.from_path� s< � � � �t�4�� �'�'��T�74����>�>���4�y�� ?�s �9A75�A�
A76c � �� # � [ R " U R R U5 I S h v�N g N! [ a [77 S e[ a n[ UeS nAff = f7fr, )r r3 r. �writerQ r rR r )r/ �itemrU s r' �send�FileWriteStream.send� sQ � � � /��$�$�T�Z�Z�%5�%5�t�<� <� <��� 0�%�4� /�� /�%�3� .�� /�s1 �A#�.: �8�: �A#�: �A �A�A � A#r N)F)r r` ri �boolrC r )rn ra rC rD ) r r! r" r# rb rc rM ro r% r r& r' r r { s; � �� �7<�
�&�
�04�
� �
� �
� /r& r N) �78__future__r �__all__�collections.abcr r �ior r79 �osr �pathlibr �typingr
r � r r r r r r �abcr r r r) r r r r& r' �<module>r{ sd �� "� �� .� -� � � �� � 4�$�+� $�� �4;9�_�&7� ;9�| /�o�~� /r&