$%hddlmZddlmZmZddlmZmZddlm Z ddl m Z ddl m Z mZmZddlmZmZmZmZmZmZdd lmZmZGd d eZGd d ZGddeeZGddeeZy)) annotations)CallableMapping)SEEK_SETUnsupportedOperation)PathLike)Path)AnyBinaryIOcast)BrokenResourceErrorClosedResourceError EndOfStreamTypedAttributeSet to_threadtyped_attribute)ByteReceiveStreamByteSendStreamcVeZdZUeZded<eZded<eZded<y)FileStreamAttributer filer pathintfilenoN)__name__ __module__ __qualname__rr__annotations__rrP/var/www/skyplay_api_hub/venv/lib/python3.12/site-packages/anyio/streams/file.pyrrs)$&D(& "D$"!#FC#r!rc.eZdZddZddZeddZy)_BaseFileStreamc||_yN_file)selfrs r"__init__z_BaseFileStream.__init__s  r!crKtj|jjd{y7wr&)rrun_syncr(closer)s r"aclosez_BaseFileStream.aclose!s$  !1!1222s -757c tjfdi}tjdrfd|tj< jj fd|tj <|S#t $rY|SwxYw)NcjSr&r'r.sr"z2_BaseFileStream.extra_attributes..'s djjr!namecBtjjSr&)r r(r3r.sr"r2z2_BaseFileStream.extra_attributes..+s4 ;Pr!c8jjSr&)r(rr.sr"r2z2_BaseFileStream.extra_attributes..2sTZZ=N=N=Pr!)rrhasattrr(rrr)r) attributess` r"extra_attributesz _BaseFileStream.extra_attributes$s $ $&84  4::v &3PJ*// 0 Q JJ   6QJ*11 2 $    sA66 BBN)rr )returnNone)r9zMapping[Any, Callable[[], Any]])rrrr*r/propertyr8r r!r"r$r$s 3r!r$c@eZdZdZeddZdd dZefd dZd dZ y) 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 cKtjt|jdd{}|t t |S7w)z{ Create a file read stream by opening the given file. :param path: path of the file to read from rbNrr,r openr r )clsrrs r" from_pathzFileReadStream.from_path@s<''T >>4$'((?s-A A A cK tj|jj|d{}|r|St7#t$rt dt $r }t|d}~wwxYwwr&) rr,r(read ValueErrorrOSErrorrr)r) max_bytesdataexcs r"receivezFileReadStream.receiveKse /"++DJJOOYGGD K H 0%4 / /%3 . /s7A)-AAA A)AA&A!!A&&A)ctKtj|jj||d{S7w)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)positionwhences r"rMzFileReadStream.seekXs+'' 6JJJJs /868cpKtj|jjd{S7w)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.s r"rQzFileReadStream.tellhs''' 8888s -646N)rstr | PathLike[str]r9r=)i)rHrr9bytes)rNrrOrr9r)r9r) rrr__doc__ classmethodrCrKrrMrQr r!r"r=r=7s0)) 7?K 9r!r=c8eZdZdZe d ddZddZy)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 cK|rdnd}tjt|j|d{}|t t |S7w)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 abwbNr@)rBrappendmoders r"rCzFileWriteStream.from_path~sEt4''T >>4$'((?s3AAAcK tj|jj|d{y7#t$rt dt $r }t|d}~wwxYwwr&)rr,r(writerFrrGr)r)itemrJs r"sendzFileWriteStream.sendsR /$$TZZ%5%5t< < < 0%4 / /%3 . /s1A -979A 9AAAA N)F)rrRr[boolr9rW)r_rSr9r:)rrrrTrUrCr`r r!r"rWrWus;7< )& )04 )  ) )/r!rWN) __future__rcollections.abcrriorrosrpathlibr typingr r r rrrrrrabcrrrr$r=rWr r!r"rjs^"--&&4$+$4;9_&7;9|/o~/r!