a xd@sjddlmZddlZddlmZddlmZddlZhdZhdZ Gdd d eZ dd dZ ddZ dS))partialN) AsyncResource) async_wraps>closefdbuffermodeerrorsline_bufferingwritablenewlinesisattyname getbufferfilenoreadableencodingseekablegetvaluerawclosed>readtruncateflushtellpeekread1seekreadinto readinto1readline writelinesreadall readlineswritecs\eZdZdZddZeddZddZfdd Zd d Z d d Z ddZ ddZ Z S)AsyncIOWrapperaIA 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 in :mod:`~io` are exposed by this wrapper, if they exist in the wrapped file object. cCs ||_dSN_wrapped)selffiler+E/var/www/html/Ranjet/env/lib/python3.9/site-packages/trio/_file_io.py__init__=szAsyncIOWrapper.__init__cCs|jS)z.object: A reference to the wrapped file objectr'r)r+r+r,wrapped@szAsyncIOWrapper.wrappedcsb|tvrt|j|S|tvrVt|j|t|j|jj|fdd}t||||St|dS)Ncs(tg|Ri|}tj|IdHSr&)rtrio to_threadrun_sync)argskwargsfuncmethr+r,wrapperLsz+AsyncIOWrapper.__getattr__..wrapper)_FILE_SYNC_ATTRSgetattrr(_FILE_ASYNC_METHODSr __class__setattrAttributeError)r)rr8r+r6r, __getattr__Fs   zAsyncIOWrapper.__getattr__csBtt}|fddtD|fddtD|S)Nc3s|]}tj|r|VqdSr&hasattrr/.0ar.r+r, Yz)AsyncIOWrapper.__dir__..c3s|]}tj|r|VqdSr&r@rBr.r+r,rEZrF)setsuper__dir__updater9r;)r)attrsr<r.r,rIWszAsyncIOWrapper.__dir__cCs|Sr&r+r.r+r+r, __aiter__]szAsyncIOWrapper.__aiter__cs|IdH}|r|StdSr&)r StopAsyncIteration)r)liner+r+r, __anext__`szAsyncIOWrapper.__anext__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)r0r1r2r(detach wrap_file)r)rr+r+r,rQgszAsyncIOWrapper.detachcsVtjdd&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)ZshieldN)r0Z CancelScoper1r2r(closeZlowlevelZcheckpoint_if_cancelledr.r+r+r,aclosers 4zAsyncIOWrapper.aclose)__name__ __module__ __qualname____doc__r-propertyr/r?rIrMrPrQrT __classcell__r+r+rLr,r%3s    r%rTc s,ttjtj|||||||| IdH}|S)a+Asynchronous version of :func:`io.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)rRr0r1r2ioopen) r*r bufferingrr newlineropener_filer+r+r, open_files rccs:fdd}|dr$|ds2|ds2tdtS)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' cst|ott|Sr&)rAcallabler:)attrr*r+r,hasszwrap_file..hasrSrr$zK{} does not implement required duck-file methods: close and (read or write)) TypeErrorformatr%)r*rgr+rfr,rRs rR)r[r\NNNTN) functoolsrr]abcrZ_utilrr0r9r;r%rcrRr+r+r+r,s   P #