U ·ddã@sÂddlmZmZddlmZddlmZddlmZm Z m Z m Z m Z m Z mZddlmZmZmZmZmZmZddlmZmZGdd „d eƒZGd d „d ƒZGd d „d eeƒZGdd„deeƒZdS)é)ÚSEEK_SETÚUnsupportedOperation)ÚPathLike)ÚPath)ÚAnyÚBinaryIOÚCallableÚDictÚMappingÚUnionÚcasté)ÚBrokenResourceErrorÚClosedResourceErrorÚ EndOfStreamÚTypedAttributeSetÚ to_threadÚtyped_attribute)ÚByteReceiveStreamÚByteSendStreamc@s8eZdZUeƒZeed<eƒZeed<eƒZ e ed<dS)ÚFileStreamAttributeÚfileÚpathÚfilenoN) Ú__name__Ú __module__Ú __qualname__rrrÚ__annotations__rrrÚint©rrú6/tmp/pip-unpacked-wheel-yaxr6kle/anyio/streams/file.pyrs rc@sJeZdZedœdd„Zddœdd„Zeeee geffdœdd „ƒZ dS) Ú_BaseFileStream)rcCs ||_dS©N©Ú_file)Úselfrrrr Ú__init__sz_BaseFileStream.__init__N©ÚreturncÃst |jj¡IdHdSr")rÚrun_syncr$Úclose©r%rrr Úaclosesz_BaseFileStream.aclosecsjtj‡fdd„i}tˆjdƒr0‡fdd„|tj<zˆj ¡Wntk rRYnX‡fdd„|tj<|S)NcsˆjSr"r#rr+rr Ú$óz2_BaseFileStream.extra_attributes..Únamecs tˆjjƒSr")rr$r/rr+rr r-(r.cs ˆj ¡Sr")r$rrr+rr r-/r.)rrÚhasattrr$rrr)r%Ú attributesrr+r Úextra_attributes!s ÿ z _BaseFileStream.extra_attributes) rrrrr&r,Úpropertyr rrr2rrrr r!sr!c@sbeZdZdZeeedfddœdd„ƒZdee dœdd „Z e feeed œd d „Z ed œdd„Z 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 ú PathLike[str])rr(cÃs&t t|ƒjd¡IdH}|tt|ƒƒS)z{ Create a file read stream by opening the given file. :param path: path of the file to read from ÚrbN©rr)rÚopenr r)Úclsrrrrr Ú from_path=szFileReadStream.from_pathé)Ú max_bytesr(c Ãslzt |jj|¡IdH}Wn@tk r4td‚Yn(tk rZ}z t|‚W5d}~XYnX|rd|St‚dSr") rr)r$ÚreadÚ ValueErrorrÚOSErrorrr)r%r<ÚdataÚexcrrr ÚreceiveHs zFileReadStream.receive)ÚpositionÚwhencer(cÃst |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%rCrDrrr rEUszFileReadStream.seekr'cÃst |jj¡IdHS)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 rFes zFileReadStream.tellN)r;)rrrÚ__doc__Ú classmethodr Ústrr:rÚbytesrBrrErFrrrr r44s   r4c@s@eZdZdZed eedfeddœdd„ƒZe ddœd d „Z dS) Ú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 Fr5)rÚappendr(cÃs2|rdnd}t t|ƒ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 ÚabÚwbNr7)r9rrLÚmoderrrr r:{s zFileWriteStream.from_pathN)Úitemr(c Ãs`zt |jj|¡IdHWn@tk r4td‚Yn(tk rZ}z t|‚W5d}~XYnXdSr")rr)r$Úwriter>rr?r)r%rPrArrr Úsend‹s  zFileWriteStream.send)F) rrrrGrHr rIÚboolr:rJrRrrrr rKrsÿ þrKN)ÚiorrÚosrÚpathlibrÚtypingrrrr r r r ÚrrrrrrÚabcrrrr!r4rKrrrr Ús  $  >