a xd@sddlmZmZddlZddlZddlZddlZddlmZm Z ddZ ddZ dd Z d d Z d d ZddZGddde ZGdddedZdej_ej`ejedS))wrapspartialN) async_wrapsFinalcCst|tjrt|}|SN) isinstancepathlibPath)valuer B/var/www/html/Ranjet/env/lib/python3.9/site-packages/trio/_path.py rewrap_path s r cst|fdd}|S)Ncs"t|j}||i|}t|Sr)getattr_wrappedr )selfargskwargsattrr  attr_namer r wrappers z!_forward_factory..wrapper)r)clsrrrr rr _forward_factorysrcs&ttffdd }|S)Ncs6|ur|jSt|r"|j}|j|}t|Sr)rrr )rotherr rrsentinelr r r s    z_forward_magic..wrapper)objectr)rrrr rr _forward_magicsrcst||jfdd}|S)NcsJt|j}t|g|Ri|tjfddIdH}dd|DS)Ncs tSr)listr funcr r 3z7iter_wrapper_factory..wrapper..css|]}t|VqdSr)r ).0itemr r r 4r"z8iter_wrapper_factory..wrapper..)rrrtrio to_threadrun_sync)rrrmethitems meth_namerr r-s z%iter_wrapper_factory..wrapperr_wrapsrr,rr r+r iter_wrapper_factory,s r0cst||jfdd}|S)Ncs<t|j}t|g|Ri|}tj|IdH}t|Sr)rrrr&r'r(r )rrrr)r r r+r r r:s z'thread_wrapper_factory..wrapperr-r/r r+r thread_wrapper_factory9s r1cs"tt||jfdd}|S)Ncs<t|j}t|g|Ri|}tj|IdH}t|Sr)rr.rr&r'r(r )rrrr)r r r+r r rEs z,classmethod_wrapper_factory..wrapper) classmethodrr.r/r r+r classmethod_wrapper_factoryDs r3cs<eZdZfddZddZddZddZd d ZZS) AsyncAutoWrapperTypecsZt|||g|_t|||t|||t|||t|||dSr)super__init___forwardtypegenerate_forwardsgenerate_wrapsgenerate_magic generate_iter)rnamebasesattrs __class__r r r6Qs zAsyncAutoWrapperType.__init__cCsz|jjD]h\}}|ds ||vr(q t|tr@|j|q t|tj rft |||}t |||q t |t |q dSN_) _forwards__dict__r* startswithrpropertyr7appendtypes FunctionTypersetattr TypeErrorr8rr?rrrr r r r9Zs   z&AsyncAutoWrapperType.generate_forwardscCs|jjD]p\}}|ds ||vr(q t|trJt||}t|||q t|tj rnt ||}t|||q t |t |q dSrB) r.rEr*rFrr2r3rKrIrJr1rLr8rMr r r r:hs    z#AsyncAutoWrapperType.generate_wrapscCs2|jD]&}t|j|}t||}t|||qdSr)rrrDrKrMr r r r;ws   z#AsyncAutoWrapperType.generate_magiccCs:|jjD](\}}||jvr t||}t|||q dSr)r.rEr* _wrap_iterr0rKrMr r r r<~s  z"AsyncAutoWrapperType.generate_iter) __name__ __module__ __qualname__r6r9r:r;r< __classcell__r r r@r r4Ps  r4cspeZdZdZejZejZgdZ gdZ ddZ ddZ fdd Z d d Zd d ZeejjddZZS)r zlA :class:`pathlib.Path` wrapper that executes blocking methods in :meth:`trio.to_thread.run_sync`. ) __str__ __bytes__ __truediv__ __rtruediv____eq____lt____le____gt____ge____hash__)globrglobiterdircGstj||_dSr)rr r)rrr r r r6sz Path.__init__cCs*||jvrt|j|}t|St|dSr)r7rrr AttributeError)rr=r r r r __getattr__s  zPath.__getattr__cst|jSr)r5__dir__r7rr@r r rbsz Path.__dir__cCsdtt|S)Nz trio.Path({}))formatreprstrrcr r r __repr__sz Path.__repr__cCs t|jSr)osfspathrrcr r r __fspath__szPath.__fspath__cs6t|jjg|Ri|}tj|IdH}t|S)zfOpen the file pointed to by the path, like the :func:`trio.open_file` function does. N)rropenr&r'r(Z wrap_file)rrrr r r r r rksz Path.open)rOrPrQ__doc__rr r.PurePathrDrrNr6rarbrgrjrrkrRr r r@r r s   r ) metaclassa Like :meth:`pathlib.Path.iterdir`, but async. This is an async method that returns a synchronous iterator, so you use it like:: for subpath in await mypath.iterdir(): ... Note that it actually loads the whole directory list into memory immediately, during the initial call. (See `issue #501 `__ for discussion.) ) functoolsrrrhrIrr&Z trio._utilrrr rrr0r1r3r4r r_rlabsolutePathLikeregisterr r r r s     64