i<:UddlmZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZmZddlZddlmZddlmZe rdd lmZmZmZmZmZmZdd lm Z hd Z!d e"d <hdZ#d e"d<edZ$eddZ%edZ&eddZ'eddZ(ede)e*dZ+ede)e*dZ,e rddl-m.Z.m/Z/Gdde/Z0Gdde/Z1Gdd e/Z2Gd!d"e/Z3Gd#d$e/Z4Gd%d&e/e'Z5Gd'd(e/Z6Gd)d*e/Z7Gd+d,e/Z8Gd-d.e/Z9Gd/d0e/Z:Gd1d2e/Z;Gd3d4e/Z<Gd5d6e/Z=Gd7d8e/Z>Gd9d:e/e+Z?Gd;de/ZAGd?d@e/e+ZBGdAdBe/ZCGdCdDe/e+ZDGdEdFe/ZEGdGdHe/ZFGdIdJe/e+ZGGdKdLe/e ZHGdMdNe/ZIGdOdPe/ZJGdQdRe/ZKGdSdTe/e(ZLGdUdVe/e(ZMGdWdXe/e+ZNGdYdZe/e'ZOGd[d\e/ZPGd]d^eee%ZQed_eRfZSee)eRgeRfZTe dddrZUe dddwZUe ddd{ZUe ddd~ZUe dddZUe dddZUe dddZU dddZUddZVdS)) annotationsN)CallableIterable)partial) IO TYPE_CHECKINGAnyAnyStrBinaryIOGenericLiteralTypeVarUnionoverload) async_wraps) AsyncResource)OpenBinaryModeOpenBinaryModeReadingOpenBinaryModeUpdatingOpenBinaryModeWriting OpenTextModeStrOrBytesPath)CapacityLimiter>rawmodenamebufferclosederrorsfilenoisattyclosefdencodinggetvaluenewlinesreadableseekablewritable getbufferline_bufferingzset[str]_FILE_SYNC_ATTRS>peekreadseektellflushread1writereadallreadintoreadlinetruncate readinto1 readlines writelines_FILE_ASYNC_METHODSFileTFileT_coT) covariantTT_coT_contra) contravariant AnyStr_co AnyStr_contra)BufferProtocolc&eZdZeddZdS) _HasClosedreturnboolcdSNselfs Y/var/www/html/nodeJS/PythonScripts/venv3.11/lib/python3.11/site-packages/trio/_file_io.pyrz_HasClosed.closedis"%#NrIrJ)__name__ __module__ __qualname__propertyrrMrQrPrHrHhs& %%% %%%rQrHc&eZdZeddZdS) _HasEncodingrIstrcdSrLrMrNs rPr$z_HasEncoding.encodingm#&3rQNrIrY)rSrTrUrVr$rMrQrPrXrXl& &&& &&&rQrXc&eZdZeddZdS) _HasErrorsrI str | NonecdSrLrMrNs rPr z_HasErrors.errorsqs(+rQN)rIr`)rSrTrUrVr rMrQrPr_r_ps& +++ +++rQr_ceZdZddZdS) _HasFileNorIintcdSrLrMrNs rPr!z_HasFileNo.filenourQNrIrd)rSrTrUr!rMrQrPrcrct$$$$$$rQrcceZdZddZdS) _HasIsATTYrIrJcdSrLrMrNs rPr"z_HasIsATTY.isattyxrfrQNrR)rSrTrUr"rMrQrPrjrjws%%%%%%rQrjc&eZdZeddZdS) _HasNewlinesrIr@cdSrLrMrNs rPr&z_HasNewlines.newlines|s$'CrQNrIr@)rSrTrUrVr&rMrQrPrmrmzs& ''' '''rQrmceZdZddZdS) _HasReadablerIrJcdSrLrMrNs rPr'z_HasReadable.readablerfrQNrR)rSrTrUr'rMrQrPrqrq''''''rQrqceZdZddZdS) _HasSeekablerIrJcdSrLrMrNs rPr(z_HasSeekable.seekablerfrQNrR)rSrTrUr(rMrQrPrurursrQruceZdZddZdS) _HasWritablerIrJcdSrLrMrNs rPr)z_HasWritable.writablerfrQNrR)rSrTrUr)rMrQrPrxrxrsrQrxc&eZdZeddZdS) _HasBufferrIr cdSrLrMrNs rPrz_HasBuffer.buffers&)crQN)rIr )rSrTrUrVrrMrQrPr{r{s& ))) )))rQr{c&eZdZeddZdS)_HasRawrI io.RawIOBasecdSrLrMrNs rPrz _HasRaw.raws'*srQN)rIr)rSrTrUrVrrMrQrPr~r~s& *** ***rQr~c&eZdZeddZdS)_HasLineBufferingrIrJcdSrLrMrNs rPr+z _HasLineBuffering.line_bufferings*-#rQNrR)rSrTrUrVr+rMrQrPrrs& --- ---rQrc&eZdZeddZdS) _HasCloseFDrIrJcdSrLrMrNs rPr#z_HasCloseFD.closefdr[rQNrR)rSrTrUrVr#rMrQrPrrr]rQrc&eZdZeddZdS)_HasNamerIrYcdSrLrMrNs rPrz _HasName.name"srQNr\)rSrTrUrVrrMrQrPrr& """ """rQrc&eZdZeddZdS)_HasModerIrYcdSrLrMrNs rPrz _HasMode.moderrQNr\)rSrTrUrVrrMrQrPrrrrQrceZdZddZdS) _CanGetValuerIrCcdSrLrMrNs rPr%z_CanGetValue.getvaluerfrQNrIrC)rSrTrUr%rMrQrPrrs,,,,,,rQrceZdZddZdS) _CanGetBufferrI memoryviewcdSrLrMrNs rPr*z_CanGetBuffer.getbufferrfrQN)rIr)rSrTrUr*rMrQrPrrs......rQrceZdZddZdS) _CanFlushrINonecdSrLrMrNs rPr1z_CanFlush.flushrfrQNrIr)rSrTrUr1rMrQrPrrrhrQrceZdZdd dZdS) _CanRead.size int | NonerIrCcdSrLrMrOrs rPr.z _CanRead.readrfrQN.)rrrIrC)rSrTrUr.rMrQrPrrCCCCCCCrQrceZdZdd dZdS) _CanRead1.rrrIbytescdSrLrMrs rPr2z_CanRead1.read1rfrQNr)rrrIr)rSrTrUr2rMrQrPrr@@@@@@@rQrceZdZddZdS) _CanReadAllrIrCcdSrLrMrNs rPr4z_CanReadAll.readallrfrQNr)rSrTrUr4rMrQrPrrs++++++rQrceZdZddZdS) _CanReadIntobufrErIrcdSrLrMrOrs rPr5z_CanReadInto.readintorfrQN)rrErIr)rSrTrUr5rMrQrPrrs======rQrceZdZddZdS) _CanReadInto1rrErIrdcdSrLrMrOrs rPr8z_CanReadInto1.readinto1rfrQN)rrErIrd)rSrTrUr8rMrQrPrrs::::::rQrceZdZdd dZdS) _CanReadLine.rrdrIrCcdSrLrMrs rPr6z_CanReadLine.readlinerfrQNrrrdrIrC)rSrTrUr6rMrQrPrrrrQrceZdZdd dZdS) _CanReadLines.hintrdrI list[AnyStr]cdSrLrM)rOrs rPr9z_CanReadLines.readlinesrfrQNr)rrdrIr)rSrTrUr9rMrQrPrrsDDDDDDDrQrceZdZdd dZdS) _CanSeekrtargetrdwhencerIcdSrLrMrOrrs rPr/z _CanSeek.seekrfrQNr)rrdrrdrIrd)rSrTrUr/rMrQrPrrrrQrceZdZddZdS)_CanTellrIrdcdSrLrMrNs rPr0z _CanTell.tellrfrQNrg)rSrTrUr0rMrQrPrrs""""""rQrceZdZdd dZdS) _CanTruncate.rrrIrdcdSrLrMrs rPr7z_CanTruncate.truncaterfrQNr)rrrIrd)rSrTrUr7rMrQrPrrsAAAAAAArQrceZdZddZdS) _CanWritedatarArIrdcdSrLrMrOrs rPr3z_CanWrite.writerfrQN)rrArIrd)rSrTrUr3rMrQrPrrs666666rQrceZdZddZdS)_CanWriteLineslinesIterable[T_contra]rIrcdSrLrMrOrs rPr:z_CanWriteLines.writelinesrfrQN)rrrIr)rSrTrUr:rMrQrPrrsGGGGGGrQrceZdZdd dZdS) _CanPeekrrrdrIrCcdSrLrMrs rPr-z _CanPeek.peekrfrQNrr)rSrTrUr-rMrQrPrrs:::::::rQrceZdZddZdS) _CanDetachrIr@cdSrLrMrNs rPdetachz_CanDetach.detachrfrQNro)rSrTrUrrMrQrPrrs%%%%%%rQrceZdZddZdS) _CanCloserIrcdSrLrMrNs rPclosez_CanClose.closerfrQNr)rSrTrUrrMrQrPrrrhrQrc eZdZdZdldZedmdZesdnd Zdofd Z dpdZ dqdZ drdZ dsdZ eredtdZedudZedvd Zedwd#Zedxd&Zedyd)Zedzd,Zed{d.Zed|d0Zed}d2Zd~d4Zdd6Zdd8Zdd:Zdd<Zdd>ZddAZddCZdddHZ dddKZ!ddMZ"ddQZ#dddRZ$ddUZ%dddZZ&dd\Z'ddd_Z(ddbZ)ddfZ*ddiZ+dddkZ,xZ-SxZ-S)AsyncIOWrapperaEA generic :class:`~io.IOBase` wrapper that implements the :term:`asynchronous file object` interface. Wrapped methods that could block are executed in :meth:`trio.to_thread.run_sync`. All properties and methods defined in :mod:`~io` are exposed by this wrapper, if they exist in the wrapped file object. filer=rIrc||_dSrL_wrapped)rOrs rP__init__zAsyncIOWrapper.__init__s  rQc|jS)z.object: A reference to the wrapped file objectrrNs rPwrappedzAsyncIOWrapper.wrappeds }rQrrYobjectc|tvrt|j|S|tvrTt|j|t |j|jj|dfd }t ||||St|) NargsCallable[..., T]kwargs,object | str | bool | CapacityLimiter | NonerIr?crKtg|Ri|}tj|d{VSrL)rtrio to_threadrun_sync)rrfuncmeths rPwrapperz+AsyncIOWrapper.__getattr__..wrappersN #49$999&99D!%!8!8!>!>>>>>>>>rQ)rrrrrIr?)r,getattrrr;r __class__setattrAttributeError)rOrrrs @rP __getattr__zAsyncIOWrapper.__getattr__s'''t}d333***t}d33T^T]-DdKK?????LK?dG,,, && &rQ Iterable[str]ctt}|fdtD|fdt D|S)Nc3FK|]}tj||VdSrLhasattrr.0arOs rP z)AsyncIOWrapper.__dir__..s4MM1GDL!4L4LMQMMMMMMrQc3FK|]}tj||VdSrLrrs rPrz)AsyncIOWrapper.__dir__..s4PP1wt|Q7O7OPQPPPPPPrQ)setsuper__dir__updater,r;)rOattrsrs` rPrzAsyncIOWrapper.__dir__stEGGOO%%&& MMMM 0MMMMMM PPPP 3PPPPPP rQAsyncIOWrapper[FileT_co]c|SrLrMrNs rP __aiter__zAsyncIOWrapper.__aiter__ s rQrO$AsyncIOWrapper[_CanReadLine[AnyStr]]r cPK|d{V}|r|StrL)r6StopAsyncIteration)rOlines rP __anext__zAsyncIOWrapper.__anext__ s8]]__$$$$$$  %K$ $rQAsyncIOWrapper[_CanDetach[T]]AsyncIOWrapper[T]cKtj|jjd{V}t |S)zLike :meth:`io.BufferedIOBase.detach`, but async. This also re-wraps the result in a new :term:`asynchronous file object` wrapper. N)rrrrr wrap_file)rOrs rPrzAsyncIOWrapper.detachs@N++DM,@AAAAAAAA~~rQAsyncIOWrapper[_CanClose]c Ktjd5tj|jjd{Vdddn #1swxYwYtjd{VdS)zLike :meth:`io.IOBase.close`, but async. This is also shielded from cancellation; if a cancellation scope is cancelled, the wrapped file object will still be safely closed. T)shieldN)r CancelScoperrrrlowlevelcheckpoint_if_cancelledrNs rPaclosezAsyncIOWrapper.acloses T * * * ? ?.))$-*=>> > > > > > > > ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?m3355555555555s0AAAAsyncIOWrapper[_HasClosed]rJcdSrLrMrNs rPrzAsyncIOWrapper.closed/s>AcrQAsyncIOWrapper[_HasEncoding]cdSrLrMrNs rPr$zAsyncIOWrapper.encoding1sADrQAsyncIOWrapper[_HasErrors]r`cdSrLrMrNs rPr zAsyncIOWrapper.errors3sDGCrQAsyncIOWrapper[_HasNewlines[T]]r?cdSrLrMrNs rPr&zAsyncIOWrapper.newlines5BE#rQAsyncIOWrapper[_HasBuffer]r cdSrLrMrNs rPrzAsyncIOWrapper.buffer7r&rQAsyncIOWrapper[_HasRaw]rcdSrLrMrNs rPrzAsyncIOWrapper.raw9@CrQ!AsyncIOWrapper[_HasLineBuffering]rdcdSrLrMrNs rPr+zAsyncIOWrapper.line_buffering;sLOCrQAsyncIOWrapper[_HasCloseFD]cdSrLrMrNs rPr#zAsyncIOWrapper.closefd=r+rQAsyncIOWrapper[_HasName]cdSrLrMrNs rPrzAsyncIOWrapper.name?9<rQAsyncIOWrapper[_HasMode]cdSrLrMrNs rPrzAsyncIOWrapper.modeAr2rQAsyncIOWrapper[_HasFileNo]cdSrLrMrNs rPr!zAsyncIOWrapper.filenoDrfrQAsyncIOWrapper[_HasIsATTY]cdSrLrMrNs rPr"zAsyncIOWrapper.isattyErfrQAsyncIOWrapper[_HasReadable]cdSrLrMrNs rPr'zAsyncIOWrapper.readableFrfrQAsyncIOWrapper[_HasSeekable]cdSrLrMrNs rPr(zAsyncIOWrapper.seekableGrfrQAsyncIOWrapper[_HasWritable]cdSrLrMrNs rPr)zAsyncIOWrapper.writableHrfrQ$AsyncIOWrapper[_CanGetValue[AnyStr]]cdSrLrMrNs rPr%zAsyncIOWrapper.getvalueIrfrQAsyncIOWrapper[_CanGetBuffer]rcdSrLrMrNs rPr*zAsyncIOWrapper.getbufferJrfrQAsyncIOWrapper[_CanFlush]c KdSrLrMrNs rPr1zAsyncIOWrapper.flushK rQ AsyncIOWrapper[_CanRead[AnyStr]]rrc KdSrLrMrs rPr.zAsyncIOWrapper.readLrErQAsyncIOWrapper[_CanRead1]rc KdSrLrMrs rPr2zAsyncIOWrapper.read1MrErQ#AsyncIOWrapper[_CanReadAll[AnyStr]]c KdSrLrMrNs rPr4zAsyncIOWrapper.readallNrErQAsyncIOWrapper[_CanReadInto]rrEc KdSrLrMrs rPr5zAsyncIOWrapper.readintoOrErQc KdSrLrMrs rPr6zAsyncIOWrapper.readlinePrErQ%AsyncIOWrapper[_CanReadLines[AnyStr]]rc KdSrLrMrNs rPr9zAsyncIOWrapper.readlinesQrErQrAsyncIOWrapper[_CanSeek]rrc KdSrLrMrs rPr/zAsyncIOWrapper.seekRrErQAsyncIOWrapper[_CanTell]c KdSrLrMrNs rPr0zAsyncIOWrapper.tellSrErQNAsyncIOWrapper[_CanTruncate]c KdSrLrMrs rPr7zAsyncIOWrapper.truncateTrErQAsyncIOWrapper[_CanWrite[T]]rc KdSrLrMrs rPr3zAsyncIOWrapper.writeUrErQ!AsyncIOWrapper[_CanWriteLines[T]]r Iterable[T]c KdSrLrMrs rPr:zAsyncIOWrapper.writelinesVrErQAsyncIOWrapper[_CanReadInto1]rc KdSrLrMrs rPr8zAsyncIOWrapper.readinto1WrErQ AsyncIOWrapper[_CanPeek[AnyStr]]c KdSrLrMrs rPr-zAsyncIOWrapper.peekXrErQ)rr=rIr)rIr=)rrYrIr)rIr)rIr )rOrrIr )rOrrIr)rOrrIr)rOrrIrJ)rOr rIrY)rOr"rIr`)rOr$rIr?)rOr'rIr )rOr)rIr)rOr,rIrd)rOr.rIrJ)rOr0rIrY)rOr3rIrY)rOr5rIrd)rOr7rIrJ)rOr9rIrJ)rOr;rIrJ)rOr=rIrJ)rOr?rIr )rOrArIr)rOrCrIr)rF)rOrGrrrIr )rOrIrrrIr)rOrKrIr )rOrMrrErIr)rOrrrdrIr )rOrPrIrr)rOrRrrdrrdrIrd)rOrTrIrdrL)rOrVrrrIrd)rOrXrr?rIrd)rOrZrr[rIr)rOr]rrErIrd)rOr_rrdrIr ).rSrTrU__doc__rrVrrrrr rrrrr$r r&rrr+r#rrr!r"r'r(r)r%r*r1r.r2r4r5r6r9r/r0r7r3r:r8r- __classcell__)rs@rPrrsX ' ' ' ' '( %%%%     6 6 6 6,` AAA A DDD D GGG G EEE E EEE E CCC C OOO O CCC C <<< < <<< <@@@@AAAAEEEEEEEEEEEEOOOOMMMMEEEEggggg`````SSSSaaaahhhhh]]]]cccccBBBBfffffSSSSiiii_____________Y,`,`,`,`rQrrrrFr _OpenFilerr bufferingrdr$r`r newliner#rJopener_Opener | NonerI AsyncIOWrapper[io.TextIOWrapper]c KdSrLrMrrrer$r rfr#rgs rP open_filerl`s (+srQr Literal[0]rAsyncIOWrapper[io.FileIO]c KdSrLrMrks rPrlrlms !$rQrLiteral[-1, 1]!AsyncIOWrapper[io.BufferedRandom]c KdSrLrMrks rPrlrlz ),rQr!AsyncIOWrapper[io.BufferedWriter]c KdSrLrMrks rPrlrlrsrQr!AsyncIOWrapper[io.BufferedReader]c KdSrLrMrks rPrlrlrsrQAsyncIOWrapper[BinaryIO]c KdSrLrMrks rPrlrls  #srQrYAsyncIOWrapper[IO[Any]]c KdSrLrMrks rPrlrls "crQAsyncIOWrapper[object]c Kttjtj|||||||| d{V}|S)a(Asynchronous version of :func:`open`. Returns: An :term:`asynchronous file object` Example:: async with await trio.open_file(filename) as f: async for line in f: pass assert f.closed See also: :func:`trio.Path.open` N)rrrrioopen) rrrer$r rfr#rgfile_s rPrlrlsn6 n%% G             E LrQAsyncIOWrapper[FileT]cd fd }|dr|ds|dstd tS) a[This wraps any file object in a wrapper that provides an asynchronous file object interface. Args: file: a :term:`file object` Returns: An :term:`asynchronous file object` that wraps ``file`` Example:: async_file = trio.wrap_file(StringIO('asdf')) assert await async_file.read() == 'asdf' attrrYrIrJc^t|ott|SrL)rcallabler)rrs rPhaszwrap_file..hass*tT""Dxd0C0C'D'DDrQrr.r3zI does not implement required duck-file methods: close and (read or write))rrYrIrJ) TypeErrorr)rrs` rPrrs$EEEEEE CLL cc&kk SS\\  ( ( (   $  rQ)rcrFNNNTN)rrdrrrerdr$r`r r`rfr`r#rJrgrhrIri)NNNTN)rrdrrrermr$rr rrfrr#rJrgrhrIrn)rFNNNTN)rrdrrrerpr$rr rrfrr#rJrgrhrIrq)rrdrrrerpr$rr rrfrr#rJrgrhrIrt)rrdrrrerpr$rr rrfrr#rJrgrhrIrv)rrdrrrerdr$rr rrfrr#rJrgrhrIrx)rrdrrYrerdr$r`r r`rfr`r#rJrgrhrIrz)rrdrrYrerdr$r`r r`rfr`r#rJrgrhrIr|)rr<rIr)W __future__rr~collections.abcrr functoolsrtypingrrr r r r r rrrr_utilrabcr _typeshedrrrrrr_syncrr,__annotations__r;r<r=r?r@rArYrrCrDtyping_extensionsrErFrHrXr_rcrjrmrqrurxr{r~rrrrrrrrrrrrrrrrrrrrrrrrdrd_OpenerrlrrMrQrPrsl """"""" ........                          ''&&&&&,!!!&  7: . . . GCLLwv&&& 7:T 2 2 2 GKet < < < e4HHH s%22222222&&&&&X&&&'''''x''',,,,,X,,,%%%%%X%%%&&&&&X&&&(((((x~((( (((((x((((((((x((((((((x(((*****X***+++++(+++.....H...'''''h'''#####8########8###-----x *---////////%%%%%H%%%DDDDD8I&DDDAAAAAHAAA,,,,,hy),,,>>>>>x>>>;;;;;;;;AAAAAx *AAAEEEEE(EEEDDDDD8DDD#####8###BBBBBxBBB77777HX&777HHHHH(+HHH;;;;;8I&;;;&&&&&Xd^&&&%%%%%H%%% }`}`}`}`}`]GH$5}`}`}`B "C' ( C:s? # ! + + + +  + ! $ $ $ $  $ !#! , , , ,  , !#! , , , ,  , !#! , , , ,  , ! # # # #  # ! " " " "  "!(((((V      rQ