a (j= @sUddlmZddlZddlmZmZddlmZddlm Z m Z m Z m Z m Z mZmZmZmZddlZddlmZddlmZe rdd lmZmZmZmZmZmZdd lmZdd l m!Z!hd Z"d e#d<hdZ$d e#d<edZ%edddZ&edZ'edddZ(edddZ)ede*e+ddZ,ede*e+ddZ-e r|ddlm.Z.m/Z/Gddde/Z0Gddde/Z1Gd d!d!e/Z2Gd"d#d#e/Z3Gd$d%d%e/Z4Gd&d'd'e/e(Z5Gd(d)d)e/Z6Gd*d+d+e/Z7Gd,d-d-e/Z8Gd.d/d/e/Z9Gd0d1d1e/Z:Gd2d3d3e/Z;Gd4d5d5e/ZGd:d;d;e/e,Z?Gdd?d?e/ZAGd@dAdAe/e,ZBGdBdCdCe/ZCGdDdEdEe/e,ZDGdFdGdGe/ZEGdHdIdIe/ZFGdJdKdKe/e,ZGGdLdMdMe/e ZHGdNdOdOe/ZIGdPdQdQe/ZJGdRdSdSe/ZKGdTdUdUe/e)ZLGdVdWdWe/e)ZMGdXdYdYe/e,ZNGdZd[d[e/e(ZOGd\d]d]e/ZPGd^d_d_eee&ZQed`eRfZSee*eRgeRfZTeddcdddedfdfdfdgdhdidj dkdlZUeddcdmdndodododgdhdpdj dqdlZUeddcdrdsdodododgdhdtdj dudlZUeddcdvdsdodododgdhdwdj dxdlZUeddcdydsdodododgdhdzdj d{dlZUeddcdmdedodododgdhd|dj d}dlZUeddcd~dedfdfdfdgdhddj ddlZUddcd~dedfdfdfdgdhddj ddlZUdddddZVdS)) annotationsN)CallableIterable)partial) IO TYPE_CHECKINGAnyAnyStrBinaryIOGenericTypeVarUnionoverload) async_wraps) AsyncResource)OpenBinaryModeOpenBinaryModeReadingOpenBinaryModeUpdatingOpenBinaryModeWriting OpenTextModeStrOrBytesPath)Literal)CapacityLimiter>isattynamebufferencodingseekablewritableclosefdclosednewlinesrawmodeline_buffering getbuffergetvaluereadablefilenoerrorszset[str]_FILE_SYNC_ATTRS>seekreadlinereadallreadintoflushwritetruncateread1peek writelines readinto1 readlinestellread_FILE_ASYNC_METHODSFileTFileT_coT) covariantTT_coT_contra) contravariant AnyStr_co AnyStr_contra)BufferProtocolc@seZdZeddddZdS) _HasClosedboolreturncCsdSNselfrKrK3E:\soccer\ml_env\Lib\site-packages\trio/_file_io.pyr!isz_HasClosed.closedN)__name__ __module__ __qualname__propertyr!rKrKrKrNrFhsrFc@seZdZeddddZdS) _HasEncodingstrrHcCsdSrJrKrLrKrKrNrmsz_HasEncoding.encodingN)rOrPrQrRrrKrKrKrNrSlsrSc@seZdZeddddZdS) _HasErrors str | NonerHcCsdSrJrKrLrKrKrNr*qsz_HasErrors.errorsN)rOrPrQrRr*rKrKrKrNrUpsrUc@seZdZddddZdS) _HasFileNointrHcCsdSrJrKrLrKrKrNr)uz_HasFileNo.filenoN)rOrPrQr)rKrKrKrNrWtsrWc@seZdZddddZdS) _HasIsATTYrGrHcCsdSrJrKrLrKrKrNrxrYz_HasIsATTY.isattyN)rOrPrQrrKrKrKrNrZwsrZc@seZdZeddddZdS) _HasNewlinesr?rHcCsdSrJrKrLrKrKrNr"|sz_HasNewlines.newlinesN)rOrPrQrRr"rKrKrKrNr[zsr[c@seZdZddddZdS) _HasReadablerGrHcCsdSrJrKrLrKrKrNr(rYz_HasReadable.readableN)rOrPrQr(rKrKrKrNr\sr\c@seZdZddddZdS) _HasSeekablerGrHcCsdSrJrKrLrKrKrNrrYz_HasSeekable.seekableN)rOrPrQrrKrKrKrNr]sr]c@seZdZddddZdS) _HasWritablerGrHcCsdSrJrKrLrKrKrNrrYz_HasWritable.writableN)rOrPrQrrKrKrKrNr^sr^c@seZdZeddddZdS) _HasBufferr rHcCsdSrJrKrLrKrKrNrsz_HasBuffer.bufferN)rOrPrQrRrrKrKrKrNr_sr_c@seZdZeddddZdS)_HasRaw io.RawIOBaserHcCsdSrJrKrLrKrKrNr#sz _HasRaw.rawN)rOrPrQrRr#rKrKrKrNr`sr`c@seZdZeddddZdS)_HasLineBufferingrGrHcCsdSrJrKrLrKrKrNr%sz _HasLineBuffering.line_bufferingN)rOrPrQrRr%rKrKrKrNrbsrbc@seZdZeddddZdS) _HasCloseFDrGrHcCsdSrJrKrLrKrKrNr sz_HasCloseFD.closefdN)rOrPrQrRr rKrKrKrNrcsrcc@seZdZeddddZdS)_HasNamerTrHcCsdSrJrKrLrKrKrNrsz _HasName.nameN)rOrPrQrRrrKrKrKrNrdsrdc@seZdZeddddZdS)_HasModerTrHcCsdSrJrKrLrKrKrNr$sz _HasMode.modeN)rOrPrQrRr$rKrKrKrNresrec@seZdZddddZdS) _CanGetValuerBrHcCsdSrJrKrLrKrKrNr'rYz_CanGetValue.getvalueN)rOrPrQr'rKrKrKrNrfsrfc@seZdZddddZdS) _CanGetBuffer memoryviewrHcCsdSrJrKrLrKrKrNr&rYz_CanGetBuffer.getbufferN)rOrPrQr&rKrKrKrNrgsrgc@seZdZddddZdS) _CanFlushNonerHcCsdSrJrKrLrKrKrNr0rYz_CanFlush.flushN)rOrPrQr0rKrKrKrNrisric@seZdZddddddZdS) _CanRead. int | NonerBsizerIcCsdSrJrKrMrnrKrKrNr9rYz _CanRead.readN).)rOrPrQr9rKrKrKrNrksrkc@seZdZddddddZdS) _CanRead1.rlbytesrmcCsdSrJrKrorKrKrNr3rYz_CanRead1.read1N).)rOrPrQr3rKrKrKrNrpsrpc@seZdZddddZdS) _CanReadAllrBrHcCsdSrJrKrLrKrKrNr.rYz_CanReadAll.readallN)rOrPrQr.rKrKrKrNrrsrrc@seZdZdddddZdS) _CanReadIntorDrl)bufrIcCsdSrJrKrMrtrKrKrNr/rYz_CanReadInto.readintoN)rOrPrQr/rKrKrKrNrssrsc@seZdZdddddZdS) _CanReadInto1rDrX)rrIcCsdSrJrKrMrrKrKrNr6rYz_CanReadInto1.readinto1N)rOrPrQr6rKrKrKrNrvsrvc@seZdZddddddZdS) _CanReadLine.rXrBrmcCsdSrJrKrorKrKrNr-rYz_CanReadLine.readlineN).)rOrPrQr-rKrKrKrNrxsrxc@seZdZddddddZdS) _CanReadLines.rX list[AnyStr])hintrIcCsdSrJrK)rMr{rKrKrNr7rYz_CanReadLines.readlinesN).)rOrPrQr7rKrKrKrNrysryc@s eZdZdddddddZdS)_CanSeekrrX)targetwhencerIcCsdSrJrKrMr}r~rKrKrNr,rYz _CanSeek.seekN)r)rOrPrQr,rKrKrKrNr|sr|c@seZdZddddZdS)_CanTellrXrHcCsdSrJrKrLrKrKrNr8rYz _CanTell.tellN)rOrPrQr8rKrKrKrNrsrc@seZdZddddddZdS) _CanTruncate.rlrXrmcCsdSrJrKrorKrKrNr2rYz_CanTruncate.truncateN).)rOrPrQr2rKrKrKrNrsrc@seZdZdddddZdS) _CanWriter@rX)datarIcCsdSrJrKrMrrKrKrNr1rYz_CanWrite.writeN)rOrPrQr1rKrKrKrNrsrc@seZdZdddddZdS)_CanWriteLineszIterable[T_contra]rj)linesrIcCsdSrJrKrMrrKrKrNr5rYz_CanWriteLines.writelinesN)rOrPrQr5rKrKrKrNrsrc@seZdZddddddZdS) _CanPeekrrXrBrmcCsdSrJrKrorKrKrNr4rYz _CanPeek.peekN)r)rOrPrQr4rKrKrKrNrsrc@seZdZddddZdS) _CanDetachr?rHcCsdSrJrKrLrKrKrNdetachrYz_CanDetach.detachN)rOrPrQrrKrKrKrNrsrc@seZdZddddZdS) _CanCloserjrHcCsdSrJrKrLrKrKrNcloserYz_CanClose.closeN)rOrPrQrrKrKrKrNrsrcseZdZdZdddddZedddd ZesBd d d d dZddfdd Z ddddZ dddddZ dddddZ ddddd Z ered!d"dd#d$Zed%d dd&d'Zed(d)dd*d+Zed,d-dd.d/Zed0d1dd2d3Zed4d5dd6d7Zed8d9dd:d;ZedZed?d dd@dAZedBd ddCdDZdEd9ddFdGZdHd"ddIdJZdKd"ddLdMZdNd"ddOdPZdQd"ddRdSZdTdddUdVZdWdXddYdZZd[ddd\d]Zdd_d`ddadbdcZ dddd`dedadfdgZ!dhdddidjZ"dkdld`dmdndoZ#ddd9ddadpdqZ$drdsddtduZ%ddwd9d9d9dxdydzZ&d{d9dd|d}Z'ddd`d9daddZ(dd-d9dddZ)ddddddZ*ddld9dddZ+ddd9ddaddZ,Z-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. r<rjfilerIcCs ||_dSrJ_wrapped)rMrrKrKrN__init__szAsyncIOWrapper.__init__rHcCs|jS)z.object: A reference to the wrapped file objectrrLrKrKrNwrappedszAsyncIOWrapper.wrappedrTobject)rrIcsl|tvrt|j|S|tvr`t|j|t|j|jj|ddddfdd }t||||St|dS)NzCallable[..., T]z,object | str | bool | CapacityLimiter | Noner>)argskwargsrIcs(tg|Ri|}tj|IdHSrJ)rtrio to_threadrun_sync)rrfuncmethrKrNwrappersz+AsyncIOWrapper.__getattr__..wrapper)r+getattrrr:r __class__setattrAttributeError)rMrrrKrrN __getattr__s   zAsyncIOWrapper.__getattr__z Iterable[str]csBtt}|fddtD|fddtD|S)Nc3s|]}tj|r|VqdSrJhasattrr.0arLrKrN rYz)AsyncIOWrapper.__dir__..c3s|]}tj|r|VqdSrJrrrLrKrNrrY)setsuper__dir__updater+r:)rMattrsrrLrNrszAsyncIOWrapper.__dir__zAsyncIOWrapper[FileT_co]cCs|SrJrKrLrKrKrN __aiter__ szAsyncIOWrapper.__aiter__z$AsyncIOWrapper[_CanReadLine[AnyStr]]r )rMrIcs|IdH}|r|StdSrJ)r-StopAsyncIteration)rMlinerKrKrN __anext__ szAsyncIOWrapper.__anext__zAsyncIOWrapper[_CanDetach[T]]zAsyncIOWrapper[T]cstj|jjIdH}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)rMr#rKrKrNrszAsyncIOWrapper.detachzAsyncIOWrapper[_CanClose]csVtjdd&tj|jjIdHWdn1s80YtjIdHdS)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)rZ CancelScoperrrrZlowlevelZcheckpoint_if_cancelledrLrKrKrNacloses 4zAsyncIOWrapper.aclosezAsyncIOWrapper[_HasClosed]rGcCsdSrJrKrLrKrKrNr!/szAsyncIOWrapper.closedzAsyncIOWrapper[_HasEncoding]cCsdSrJrKrLrKrKrNr1szAsyncIOWrapper.encodingzAsyncIOWrapper[_HasErrors]rVcCsdSrJrKrLrKrKrNr*3szAsyncIOWrapper.errorszAsyncIOWrapper[_HasNewlines[T]]r>cCsdSrJrKrLrKrKrNr"5szAsyncIOWrapper.newlineszAsyncIOWrapper[_HasBuffer]r cCsdSrJrKrLrKrKrNr7szAsyncIOWrapper.bufferzAsyncIOWrapper[_HasRaw]racCsdSrJrKrLrKrKrNr#9szAsyncIOWrapper.rawz!AsyncIOWrapper[_HasLineBuffering]rXcCsdSrJrKrLrKrKrNr%;szAsyncIOWrapper.line_bufferingzAsyncIOWrapper[_HasCloseFD]cCsdSrJrKrLrKrKrNr =szAsyncIOWrapper.closefdzAsyncIOWrapper[_HasName]cCsdSrJrKrLrKrKrNr?szAsyncIOWrapper.namezAsyncIOWrapper[_HasMode]cCsdSrJrKrLrKrKrNr$AszAsyncIOWrapper.modezAsyncIOWrapper[_HasFileNo]cCsdSrJrKrLrKrKrNr)DrYzAsyncIOWrapper.filenozAsyncIOWrapper[_HasIsATTY]cCsdSrJrKrLrKrKrNrErYzAsyncIOWrapper.isattyzAsyncIOWrapper[_HasReadable]cCsdSrJrKrLrKrKrNr(FrYzAsyncIOWrapper.readablezAsyncIOWrapper[_HasSeekable]cCsdSrJrKrLrKrKrNrGrYzAsyncIOWrapper.seekablezAsyncIOWrapper[_HasWritable]cCsdSrJrKrLrKrKrNrHrYzAsyncIOWrapper.writablez$AsyncIOWrapper[_CanGetValue[AnyStr]]cCsdSrJrKrLrKrKrNr'IrYzAsyncIOWrapper.getvaluezAsyncIOWrapper[_CanGetBuffer]rhcCsdSrJrKrLrKrKrNr&JrYzAsyncIOWrapper.getbufferzAsyncIOWrapper[_CanFlush]csdSrJrKrLrKrKrNr0KrYzAsyncIOWrapper.flushz AsyncIOWrapper[_CanRead[AnyStr]]rl)rMrnrIcsdSrJrKrorKrKrNr9LrYzAsyncIOWrapper.readzAsyncIOWrapper[_CanRead1]rqcsdSrJrKrorKrKrNr3MrYzAsyncIOWrapper.read1z#AsyncIOWrapper[_CanReadAll[AnyStr]]csdSrJrKrLrKrKrNr.NrYzAsyncIOWrapper.readallzAsyncIOWrapper[_CanReadInto]rD)rMrtrIcsdSrJrKrurKrKrNr/OrYzAsyncIOWrapper.readintocsdSrJrKrorKrKrNr-PrYzAsyncIOWrapper.readlinez%AsyncIOWrapper[_CanReadLines[AnyStr]]rzcsdSrJrKrLrKrKrNr7QrYzAsyncIOWrapper.readlinesrzAsyncIOWrapper[_CanSeek])rMr}r~rIcsdSrJrKrrKrKrNr,RrYzAsyncIOWrapper.seekzAsyncIOWrapper[_CanTell]csdSrJrKrLrKrKrNr8SrYzAsyncIOWrapper.tellNzAsyncIOWrapper[_CanTruncate]csdSrJrKrorKrKrNr2TrYzAsyncIOWrapper.truncatezAsyncIOWrapper[_CanWrite[T]])rMrrIcsdSrJrKrrKrKrNr1UrYzAsyncIOWrapper.writez!AsyncIOWrapper[_CanWriteLines[T]]z Iterable[T])rMrrIcsdSrJrKrrKrKrNr5VrYzAsyncIOWrapper.writelineszAsyncIOWrapper[_CanReadInto1])rMrrIcsdSrJrKrwrKrKrNr6WrYzAsyncIOWrapper.readinto1z AsyncIOWrapper[_CanPeek[AnyStr]]csdSrJrKrorKrKrNr4XrYzAsyncIOWrapper.peek)r)r)r)r)N)r).rOrPrQ__doc__rrRrrrrrrrrr!rr*r"rr#r%r rr$r)rr(rrr'r&r0r9r3r.r/r-r7r,r8r2r1r5r6r4 __classcell__rKrKrrNrsj rrrr _OpenFilerrXrVrGz_Opener | Nonez AsyncIOWrapper[io.TextIOWrapper]) rr$ bufferingrr*newliner openerrIcsdSrJrKrr$rrr*rr rrKrKrN open_file`s rrz Literal[0]rjzAsyncIOWrapper[io.FileIO]csdSrJrKrrKrKrNrms rzLiteral[-1, 1]z!AsyncIOWrapper[io.BufferedRandom]csdSrJrKrrKrKrNrzs rz!AsyncIOWrapper[io.BufferedWriter]csdSrJrKrrKrKrNrs rz!AsyncIOWrapper[io.BufferedReader]csdSrJrKrrKrKrNrs zAsyncIOWrapper[BinaryIO]csdSrJrKrrKrKrNrs rTzAsyncIOWrapper[IO[Any]]csdSrJrKrrKrKrNrs zAsyncIOWrapper[object]c s,ttjtj|||||||| IdH}|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) rr$rrr*rr rfile_rKrKrNrs zAsyncIOWrapper[FileT]rcsBdddfdd }|dr,|ds:|ds:td 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' rTrG)attrrIcst|ott|SrJ)rcallabler)rrrKrNhasszwrap_file..hasrr9r1zI does not implement required duck-file methods: close and (read or write)) TypeErrorr)rrrKrrNrs r)rrNNNTN)NNNTN)rNNNTN)rNNNTN)rNNNTN)NNNTN)rNNNTN)rrNNNTN)W __future__rrcollections.abcrr functoolsrtypingrrrr r r r r rrZ_utilrabcrZ _typeshedrrrrrrZtyping_extensionsrZ_syncrr+__annotations__r:r;r<r>r?r@rTrqrBrCrDrErFrSrUrWrZr[r\r]r^r_r`rbrcrdrerfrgrirkrprrrsrvrxryr|rrrrrrrrrXrZ_OpenerrrrKrKrKrNs ,          " " " " " " " +