o 6Wj@sddlmZdZddlmZmZddlmZmZddl m Z ddl m Z ddl mZmZdd lmZmZmZmZmZmZdd lmZmZGd d d eZGd ddZGdddeeZGdddeeZdS)) annotations)FileReadStreamFileStreamAttributeFileWriteStream)CallableMapping)SEEK_SETUnsupportedOperation)PathLike)Path)IOAny)BrokenResourceErrorClosedResourceError EndOfStreamTypedAttributeSet to_threadtyped_attribute)ByteReceiveStreamByteSendStreamc@s8eZdZUeZded<eZded<eZded<dS)r IO[bytes]filer pathintfilenoN)__name__ __module__ __qualname__rr__annotations__rrr r a/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/anyio/streams/file.pyrs rc@s.eZdZd ddZdddZedd d Zd S)_BaseFileStreamrrcCs ||_dSN_file)selfrr r r!__init__$s z_BaseFileStream.__init__returnNonecst|jjIdHdSr#)rrun_syncr%closer&r r r!aclose'sz_BaseFileStream.acloseMapping[Any, Callable[[], Any]]csjtjfddi}tjdrfdd|tj<zjWn ty)Y|Swfdd|tj<|S)NcsjSr#r$r r,r r!-sz2_BaseFileStream.extra_attributes..namecs tjjSr#)r r%r0r r,r r!r/1s cs jSr#)r%rr r,r r!r/8s )rrhasattrr%rrr )r& attributesr r,r!extra_attributes*s  z _BaseFileStream.extra_attributesN)rr)r(r))r(r.)rrrr'r-propertyr3r r r r!r"#s   r"c@sBeZdZdZedddZddd d ZefdddZdddZ dS)rz 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}||S)z{ Create a file read stream by opening the given file. :param path: path of the file to read from rbNrr*r open)clsrrr r r! from_pathFszFileReadStream.from_path max_bytesrbytesc sj|dkr tdz t|jj|IdH}Wnty tdty.}zt|d}~ww|r3|St)Nz$max_bytes must be a positive integer) ValueErrorrr*r%readrOSErrorrr)r&r<dataexcr r r!receiveQs 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&rErFr r r!rGaszFileReadStream.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,r r r!rHqs zFileReadStream.tellN)rr5r(r)r;)r<rr(r=)rErrFrr(r)r(r) rrr__doc__ classmethodr:rDrrGrHr r r r!r=s  rc@s,eZdZdZe dddd Zdd dZdS)rz 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 Frr5appendboolr(cs.|rdnd}tt|j|IdH}||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 abwbNr7)r9rrKmoderr r r!r:s zFileWriteStream.from_pathitemr=r)c sPzt|jj|IdHWdStytdty'}zt|d}~wwr#)rr*r%writer?rrAr)r&rPrCr r r!sends zFileWriteStream.sendN)F)rr5rKrLr(r)rPr=r(r))rrrrIrJr:rRr r r r!r~s rN) __future__r__all__collections.abcrriorr osr pathlibr typingr r rrrrrrabcrrrr"rrr r r r!s     A