o d@sddlmZmZddlmZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZmZmZmZmZddlmZmZGdd d eZGd d d ZGd d d eeZGdddeeZdS))SEEK_SETUnsupportedOperation)PathLike)Path)AnyBinaryIOCallableDictMappingUnioncast)BrokenResourceErrorClosedResourceError EndOfStreamTypedAttributeSet to_threadtyped_attribute)ByteReceiveStreamByteSendStreamc@s8eZdZUeZeed<eZeed<eZ e ed<dS)FileStreamAttributefilepathfilenoN) __name__ __module__ __qualname__rrr__annotations__rrrintrr=/usr/local/lib/python3.10/dist-packages/anyio/streams/file.pyrs rc@sFeZdZdefddZd ddZedeee gefffdd Z dS) _BaseFileStreamrcCs ||_dSN_file)selfrrrr __init__s z_BaseFileStream.__init__returnNcst|jjIdHdSr")rrun_syncr$closer%rrr aclosesz_BaseFileStream.aclosecsjtjfddi}tjdrfdd|tj<zjWn ty)Y|Swfdd|tj<|S)NcsjSr"r#rr*rr $sz2_BaseFileStream.extra_attributes..namecs tjjSr")rr$r-rr*rr r,(s cs jSr")r$rrr*rr r,/s )rrhasattrr$rrr)r% attributesrr*r extra_attributes!s  z _BaseFileStream.extra_attributes)r'N) rrrrr&r+propertyr rrr0rrrr r!s  $r!c@sjeZdZdZedeedfddfddZddede fd d Z e fd ed edefd dZ defddZ dS)FileReadStreamz 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 r PathLike[str]r'cs(tt|jdIdH}|tt|S)z{ Create a file read stream by opening the given file. :param path: path of the file to read from rbNrr(ropenr r)clsrrrrr from_path=szFileReadStream.from_path max_bytesc sZz t|jj|IdH}Wntytdty&}zt|d}~ww|r+|Str") rr(r$read ValueErrorrOSErrorrr)r%r:dataexcrrr receiveHs zFileReadStream.receivepositionwhencecst|jj||IdHS)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)rr(r$seek)r%rArBrrr rCUszFileReadStream.seekcst|jjIdHS)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)rr(r$tellr*rrr rDes zFileReadStream.tellN)r9)rrr__doc__ classmethodr strr8rbytesr@rrCrDrrrr r24s  r2c@sHeZdZdZe d deedfdeddfddZd e dd fd d Z d S)FileWriteStreamz 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 Frr3appendr'cs4|rdnd}tt|j|IdH}|tt|S)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 abwbNr5)r7rrJmoderrrr r8{s zFileWriteStream.from_pathitemNc sPzt|jj|IdHWdStytdty'}zt|d}~wwr")rr(r$writer<rr=r)r%rNr?rrr sends zFileWriteStream.send)F) rrrrErFr rGboolr8rHrPrrrr rIrs  rIN)iorrosrpathlibrtypingrrrr r r r rrrrrrabcrrrr!r2rIrrrr s  $  >