o h@sddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl m Z mZmZddlmZmZmZmZmZmZdd lmZmZGd d d eZGd d d ZGdddeeZGdddeeZdS)) annotations)CallableMapping)SEEK_SETUnsupportedOperation)PathLike)Path)AnyBinaryIOcast)BrokenResourceErrorClosedResourceError EndOfStreamTypedAttributeSet to_threadtyped_attribute)ByteReceiveStreamByteSendStreamc@s8eZdZUeZded<eZded<eZded<dS)FileStreamAttributer filerpathintfilenoN)__name__ __module__ __qualname__rr__annotations__rrrrf/var/www/html/construction_image-detection-poc/venv/lib/python3.10/site-packages/anyio/streams/file.pyrs rc@s.eZdZd ddZdddZedd d Zd S)_BaseFileStreamrr cCs ||_dSN_file)selfrrrr__init__s z_BaseFileStream.__init__returnNonecst|jjIdHdSr!)rrun_syncr#closer$rrraclose!sz_BaseFileStream.acloseMapping[Any, Callable[[], Any]]csjtjfddi}tjdrfdd|tj<zjWn ty)Y|Swfdd|tj<|S)NcsjSr!r"rr*rr'sz2_BaseFileStream.extra_attributes..namecs tjjSr!)rr#r.rr*rrr-+s cs jSr!)r#rrr*rrr-2s )rrhasattrr#rrr)r$ attributesrr*rextra_attributes$s  z _BaseFileStream.extra_attributesN)rr )r&r')r&r,)rrrr%r+propertyr1rrrrr s   r c@sBeZdZdZedddZddd d ZefdddZdddZ 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 rstr | 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_bytesrbytesc sZz t|jj|IdH}Wntytdty&}zt|d}~ww|r+|Str!) rr(r#read ValueErrorrOSErrorr r)r$r;dataexcrrrreceiveKs 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$rCrDrrrrEXszFileReadStream.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*rrrrFhs zFileReadStream.tellN)rr4r&r3)r:)r;rr&r<)rCrrDrr&r)r&r) rrr__doc__ classmethodr9rBrrErFrrrrr37s   r3c@s,eZdZdZe dddd Zdd dZdS)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 Frr4appendboolr&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 abwbNr6)r8rrJmoderrrrr9~s zFileWriteStream.from_pathitemr<r'c sPzt|jj|IdHWdStytdty'}zt|d}~wwr!)rr(r#writer>rr?r )r$rOrArrrsends zFileWriteStream.sendN)F)rr4rJrKr&rI)rOr<r&r')rrrrGrHr9rQrrrrrIus rIN) __future__rcollections.abcrriorrosrpathlibrtypingr r r r rrrrrabcrrrr r3rIrrrrs     >