U &%e@sddlmZddlmZmZddlmZddlmZddl m Z m Z m Z m Z mZddlmZmZmZmZmZmZddlmZmZGd d d eZGd d d ZGd ddeeZGdddeeZdS)) annotations)SEEK_SETUnsupportedOperation)PathLike)Path)AnyBinaryIOCallableMappingcast)BrokenResourceErrorClosedResourceError EndOfStreamTypedAttributeSet to_threadtyped_attribute)ByteReceiveStreamByteSendStreamc@s8eZdZUeZded<eZded<eZded<dS)FileStreamAttributerfilerpathintfilenoN)__name__ __module__ __qualname__rr__annotations__rrrrQ/var/www/html/Darija-Ai-API/env/lib/python3.8/site-packages/anyio/streams/file.pyrs rc@s:eZdZddddZddddZed dd d Zd S) _BaseFileStreamr)rcCs ||_dSN_file)selfrrrr__init__sz_BaseFileStream.__init__Nonereturncst|jjIdHdSr!)rrun_syncr#closer$rrraclose sz_BaseFileStream.aclosezMapping[Any, Callable[[], Any]]csjtjfddi}tjdr0fdd|tj<zjWntk rRYnXfdd|tj<|S)NcsjSr!r"rr+rr&z2_BaseFileStream.extra_attributes..namecs tjjSr!)rr#r/rr+rrr-*r.cs jSr!)r#rrr+rrr-1r.)rrhasattrr#rrr)r$ attributesrr+rextra_attributes#s  z _BaseFileStream.extra_attributesN)rrrr%r,propertyr2rrrrr sr c@sZeZdZdZedddddZdddd d d Zefdddd d dZddddZ 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 str | PathLike[str])rr(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_pathrbytes) max_bytesr(c slzt|jj|IdH}Wn@tk r4tdYn(tk rZ}z t|W5d}~XYnX|rd|StdSr!) rr)r#read ValueErrorrOSErrorr r)r$r=dataexcrrrreceiveJs zFileReadStream.receive)positionwhencer(cst|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$rDrErrrrFWszFileReadStream.seekr'cst|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+rrrrGgs zFileReadStream.tellN)r;) rrr__doc__ classmethodr:rCrrFrGrrrrr46s   r4c@s8eZdZdZedddddddZdd d d d Zd 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 Fr5bool)rappendr(cs2|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 abwbNr7)r9rrLmoderrrrr:}s zFileWriteStream.from_pathr<r&)itemr(c s`zt|jj|IdHWn@tk r4tdYn(tk rZ}z t|W5d}~XYnXdSr!)rr)r#writer?rr@r )r$rPrBrrrsends  zFileWriteStream.sendN)F)rrrrHrIr:rRrrrrrJts rJN) __future__riorrosrpathlibrtypingrrr r r r rrrrrabcrrrr r4rJrrrrs     >