oPj@ddlmZdZddlmZmZddlmZmZddl m Z ddl m Z ddl mZmZdd lmZmZmZmZmZmZmZdd lmZmZdd lmZGd d eZGddZGddeeZGddeeZ y)) annotations)FileReadStreamFileStreamAttributeFileWriteStream)CallableMapping)SEEK_SETUnsupportedOperation)PathLike)Path)IOAny)BrokenResourceError CancelScopeClosedResourceError EndOfStreamTypedAttributeSet to_threadtyped_attribute)ByteReceiveStreamByteSendStream)checkpoint_if_cancelledcVeZdZUeZded<eZded<eZded<y)r IO[bytes]filer pathintfilenoN)__name__ __module__ __qualname__rr__annotations__rrW/home/oem/CyberBrain26-unified/.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%cKtd5tj|jjd{dddt d{y7#1swYxYw7w)NT)shield)rrrun_syncr,closerr-s r&aclosez_BaseFileStream.aclose)sZ  % 7$$TZZ%5%56 6 6 7&''' 7 7 7 (s8 A,-AAAA,A*A,AA'#A,c tjfdi}tjdrfd|tj< jj fd|tj <|S#t $rY|SwxYw)NcjSr*r+r3sr&z2_BaseFileStream.extra_attributes..2s djjr%namecBtjjSr*)r r,r8r3sr&r7z2_BaseFileStream.extra_attributes..6s4 ;Pr%c8jjSr*)r,rr3sr&r7z2_BaseFileStream.extra_attributes..=sTZZ=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)r>zMapping[Any, Callable[[], Any]])r r!r"r.r4propertyr=r$r%r&r(r(%s ( r%r(c@eZdZdZeddZdd dZefd dZd dZ y) 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 cKtjt|jdd{}||S7 w)z{ Create a file read stream by opening the given file. :param path: path of the file to read from rbNrr1r open)clsrrs r& from_pathzFileReadStream.from_pathKs4''T >>4y?s ->< >cK|dkr td tj|jj|d{}|r|St7#t$rt dt $r }t|d}~wwxYww)Nz$max_bytes must be a positive integer) ValueErrorrr1r,readrOSErrorrr)r- max_bytesdataexcs r&receivezFileReadStream.receiveVsx q=CD D /"++DJJOOYGGD K H 0%4 / /%3 . /s:A9-AAA A9AA6*A11A66A9ctKtj|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)rr1r,seek)r-positionwhences r&rRzFileReadStream.seekfs+'' 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)rr1r,tellr3s r&rVzFileReadStream.tellvs''' 8888s -646N)rstr | PathLike[str]r>r)i)rMrr>bytes)rSrrTrr>r)r>r) r r!r"__doc__ classmethodrGrPr rRrVr$r%r&rrBs0 7?K 9r%rc8eZdZdZe d ddZddZy)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 cK|rdnd}tjt|j|d{}||S7 w)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 abwbNrD)rFrappendmoders r&rGzFileWriteStream.from_paths=t4''T >>4y?s3AA AcK tj|jj|d{y7#t$rt dt $r }t|d}~wwxYwwr*)rr1r,writerJrrLr)r-itemrOs r&sendzFileWriteStream.sendsR /$$TZZ%5%5t< < < 0%4 / /%3 . /s1A -979A 9AAAA N)F)rrWr_boolr>r)rcrXr>r?)r r!r"rYrZrGrdr$r%r&rrs;7< & 04    /r%rN)! __future__r__all__collections.abcrrior r osr pathlibr typingr rrrrrrrrabcrrlowlevelrrr(rrr$r%r&rpsl"  .-4.$+$:>9_&7>9B/o~/r%