U
|
Z ±d« ã @ s° d dl mZmZ d dlZd dlZd dlZd dlZd dlmZm Z dd Z
|
dd Z dd Z d
|
d Z d d Zdd ZG dd de ZG dd dedZdej_ej`ej e¡ dS )é )ÚwrapsÚpartialN)Ú async_wrapsÚFinalc C s t | tjrt| } | S ©N)Ú
|
isinstanceÚpathlibÚPath)Úvalue© r úAd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_path.pyÚ rewrap_path s r c s t | fdd}|S )Nc s t | j }|||}t|S r )ÚgetattrÚ_wrappedr )ÚselfÚargsÚkwargsÚattrr
|
©Ú attr_namer r Úwrapper s
|
z!_forward_factory.<locals>.wrapper)r )Úclsr r r r r r Ú_forward_factory s r c s& t t f fdd }|S )Nc s6 |kr | j S t|r"|j } | j |}t|S r )r r r )r Úotherr
|
©r r Úsentinelr r r s
|
|
z _forward_magic.<locals>.wrapper)Úobjectr )r r r r r r Ú_forward_magic s r c s t | | j fdd}|S )Nc sD t | j}t|f|| tj fdd¡I d H }dd |D S )Nc s
|
t S r )Úlistr ©Úfuncr r Ú<lambda>3 ó z7iter_wrapper_factory.<locals>.wrapper.<locals>.<lambda>c s s | ]}t |V qd S r )r )Ú.0Úitemr r r Ú <genexpr>4 s z8iter_wrapper_factory.<locals>.wrapper.<locals>.<genexpr>)r r r ÚtrioÚ to_threadÚrun_sync)r r r ÚmethÚitems©Ú meth_namer r r - s z%iter_wrapper_factory.<locals>.wrapper©r Ú_wraps©r r, r r r+ r Úiter_wrapper_factory, s r0 c s t | | j fdd}|S )Nc s6 t | j }t|f||}tj |¡I d H }t|S r )r r r r& r' r( r )r r r r) r r
|
r+ r r r : s z'thread_wrapper_factory.<locals>.wrapperr- r/ r r+ r Úthread_wrapper_factory9 s r1 c s" t t| | j fdd}|S )Nc s6 t | j }t|f||}tj |¡I d H }t|S r )r r. r r& r' r( r )r r r r) r r
|
r+ r r r E s z,classmethod_wrapper_factory.<locals>.wrapper)Ú classmethodr r. r/ r r+ r Úclassmethod_wrapper_factoryD s r3 c s< e Zd Z fddZdd Zdd Zdd Zd d
|
Z ZS ) ÚAsyncAutoWrapperTypec sZ t |||¡ g | _t| | |¡ t| | |¡ t| | |¡ t| | |¡ d S r )ÚsuperÚ__init__Ú_forwardÚtypeÚgenerate_forwardsÚgenerate_wrapsÚgenerate_magicÚ generate_iter)r ÚnameÚbasesÚattrs©Ú __class__r r r6 Q s z AsyncAutoWrapperType.__init__c C sz | j j ¡ D ]h\}}| d¡s ||kr(q t|tr@| j |¡ q t|tj rft
|
| ||}t | || q t |t |q d S ©NÚ_)Ú _forwardsÚ__dict__r* Ú
|
startswithr Úpropertyr7 ÚappendÚtypesÚ FunctionTyper ÚsetattrÚ TypeErrorr8 ©r r? r r r r r r r9 Z s
|
z&AsyncAutoWrapperType.generate_forwardsc C s | j j ¡ D ]p\}}| d¡s ||kr(q t|trJt| |}t| || q t|tj rnt
|
| |}t| || q t |t |q d S rB ) r. rE r* rF r r2 r3 rK rI rJ r1 rL r8 rM r r r r: h s
|
|
|
z#AsyncAutoWrapperType.generate_wrapsc C s2 | j D ]&}t| j|}t | |}t| || qd S r )r r rD rK rM r r r r; w s
|
|
z#AsyncAutoWrapperType.generate_magicc C s: | j j ¡ D ](\}}|| jkr t| |}t| || q d S r )r. rE r* Ú
|
_wrap_iterr0 rK rM r r r r< ~ s
|
|
z"AsyncAutoWrapperType.generate_iter) Ú__name__Ú
|
__module__Ú __qualname__r6 r9 r: r; r< Ú __classcell__r r r@ r r4 P s
|
r4 c
|
s e Zd ZdZejZejZdddddddd d
|
d g
|
Z d d dgZ
|
dd Z dd Z fddZ dd Zdd Zeejjdd Z ZS )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__ÚglobÚrglobÚiterdirc G s t j| | _d S r )r r r )r r r r r r6 s z Path.__init__c C s* || j kr t| j|}t|S t|d S r )r7 r r r ÚAttributeError)r r= r
|
r r r Ú __getattr__ s
|
zPath.__getattr__c s t ¡ | j S r )r5 Ú__dir__r7 ©r r@ r r rb ¥ s z Path.__dir__c C s d tt| ¡S )Nz trio.Path({}))ÚformatÚreprÚstrrc r r r Ú__repr__¨ s z Path.__repr__c C s t | j¡S r )ÚosÚfspathr rc r r r Ú
|
__fspath__« s zPath.__fspath__c Ï s0 t | jjf||}tj |¡I dH }t |¡S )zfOpen the file pointed to by the path, like the :func:`trio.open_file`
|
function does.
|
|
N)r r Úopenr& r' r( Z wrap_file)r r r r r
|
r r r rk ® s z Path.open)rO rP rQ Ú__doc__r r r. ÚPurePathrD r rN r6 ra rb rg rj r rk rR r 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
|
<https://github.com/python-trio/trio/issues/501>`__ for discussion.)
|
|
)Ú functoolsr r rh rI r r& Z
|
trio._utilr r r r r r0 r1 r3 r4 r r_ rl ÚabsoluteÚPathLikeÚregisterr r r r Ú<module> s
|
64
|
