U
|
Z ±dÝ. ã @ s d dl mZ d dlZd dlZd dlZd dlZd dlmZmZ d dl Z
|
d dl Z d dl Z d dl mZ d dlZejdkr¢d dlZe ¡ Ze d¡ e d¡ZeedZnd d
|
Zd d Zd d ZG dd dZdd Z dd Z G dd dZ G dd deZ e
|
d¡Z!G dd de Z"d d Z#dS ) é )ÚABCMetaN)ÚwrapsÚupdate_wrapper)Ú
|
isasyncgenÚntzint raise(int);z!api-ms-win-crt-runtime-l1-1-0.dllÚraisec C s t t ¡ | ¡ d S ©N)ÚsignalZ pthread_killÚ threadingÚ get_ident)Úsignum© r úAd:\z\workplace\vscode\pyvenv\venv\Lib\site-packages\trio/_util.pyÚ signal_raise@ s r c C s8 z t t jt t j¡¡ W dS tk
|
r2 Y dS X dS )z7Attempt to reliably check if we are in the main thread.TFN)r ÚSIGINTÚ getsignalÚ
|
ValueErrorr r r r Úis_main_threadL s
|
r c G sÀ dd }z | | }W nV t k
|
rj t| tjjrL| ¡ t dj| dd || rdt d | ¡d Y nX t|tjjs¼||rt d |¡t|r¦t d |¡t d t| d | ¡|S )
|
Nc S s: t | tjjrdS t| dd d k r&dS | jjdkr6dS dS )NTZ_asyncio_future_blocking)ZFutureZDeferredF)Ú
|
isinstanceÚ collectionsÚabcÚ GeneratorÚgetattrÚ __class__Ú__name__)Úvaluer r r Ú&_return_value_looks_like_wrong_libraryZ s zBcoroutine_or_error.<locals>._return_value_looks_like_wrong_librarya Trio was expecting an async function, but instead it got a coroutine object {async_fn!r}
|
|
Probably you did something like:
|
|
trio.run({async_fn.__name__}(...)) # incorrect!
|
nursery.start_soon({async_fn.__name__}(...)) # incorrect!
|
|
Instead, you want (notice the parentheses!):
|
|
trio.run({async_fn.__name__}, ...) # correct!
|
nursery.start_soon({async_fn.__name__}, ...) # correct!)Úasync_fnuÊ Trio was expecting an async function, but instead it got {!r} â are you trying to use a library written for asyncio/twisted/tornado or similar? That won't work without some sort of compatibility shim.u¥ Trio got unexpected {!r} â are you trying to use a library written for asyncio/twisted/tornado or similar? That won't work without some sort of compatibility shim.zEstart_soon expected an async function but got an async generator {!r}zCTrio expected an async function, but {!r} appears to be synchronousÚ __qualname__) Ú TypeErrorr r r Ú CoroutineÚcloseÚformatr r )r Úargsr Úcoror r r Úcoroutine_or_errorY sR ôÿñýÿûþÿÿÿ
|
ÿÿr% c @ s( e Zd ZdZdd Zdd Zdd ZdS ) ÚConflictDetectora Detect when two tasks are about to perform operations that would
|
conflict.
|
|
Use as a synchronous context manager; if two tasks enter it at the same
|
time then the second one raises an error. You can use it when there are
|
two pieces of code that *would* collide and need a lock if they ever were
|
called at the same time, but that should never happen.
|
|
We use this in particular for things like, making sure that two different
|
tasks don't call sendall simultaneously on the same stream.
|
|
c C s || _ d| _d S ©NF)Ú_msgÚ_held)ÚselfÚmsgr r r Ú__init__¸ s zConflictDetector.__init__c C s | j rt | j¡nd| _ d S )NT)r) ÚtrioZBusyResourceErrorr( )r* r r r Ú __enter__¼ s zConflictDetector.__enter__c G s
|
d| _ d S r' )r) )r* r# r r r Ú__exit__Â s zConflictDetector.__exit__N)r Ú
|
__module__r Ú__doc__r, r. r/ r r r r r& ª s r& c s fdd}|S )z@Similar to wraps, but for async wrappers of non-async functions.c s0 | _ d j f¡| _d jj ¡| _| S )NÚ.z,Like :meth:`~{}.{}.{}`, but async.
|
|
)r Újoinr r" r0 r1 )Úfunc©Ú attr_nameÚclsÚ wrapped_clsr r Ú decoratorÉ s ýz async_wraps.<locals>.decoratorr )r7 r8 r6 r9 r r5 r Ú async_wrapsÆ s r: c sD t fdd | ¡ D ] \} d¡s | q d S )Nc s t |krd S t |¡ t|dd }|d k r| d¡r|_t|drbd|jkrb||_| |_t|t r|j
|
¡ D ] \}} d | || qvd S )Nr0 ztrio.r r2 ) ÚidÚaddr Ú
|
startswithr0 Úhasattrr r r ÚtypeÚ__dict__Úitems)ÚqualnameÚnameÚobjÚmodr6 Ú
|
attr_value©Úfix_oneÚ module_nameZobjnameZseen_idsr r rH Û s
|
z&fixup_module_metadata.<locals>.fix_oneÚ_)ÚsetrA r= )rI Ú namespacerD r rG r Úfixup_module_metadataØ s
|
|
rM c @ s( e Zd ZdZdd Zdd Zdd ZdS ) Úgeneric_functiona; Decorator that makes a function indexable, to communicate
|
non-inferrable generic type parameters to a static type checker.
|
|
If you write::
|
|
@generic_function
|
def open_memory_channel(max_buffer_size: int) -> Tuple[
|
SendChannel[T], ReceiveChannel[T]
|
]: ...
|
|
it is valid at runtime to say ``open_memory_channel[bytes](5)``.
|
This behaves identically to ``open_memory_channel(5)`` at runtime,
|
and currently won't type-check without a mypy plugin or clever stubs,
|
but at least it becomes possible to write those.
|
c C s t | | || _d S r )r Ú_fn)r* Úfnr r r r, s
|
zgeneric_function.__init__c O s | j ||S r )rO )r* r# Úkwargsr r r Ú__call__ s zgeneric_function.__call__c C s | S r r )r* rJ r r r Ú __getitem__ s z generic_function.__getitem__N)r r0 r r1 r, rR rS r r r r rN ô s rN c s e Zd ZdZ fddZ ZS )ÚFinala< Metaclass that enforces a class to be final (i.e., subclass not allowed).
|
|
If a class uses this metaclass like this::
|
|
class SomeClass(metaclass=Final):
|
pass
|
|
The metaclass will ensure that no sub class can be created.
|
|
Raises
|
------
|
- TypeError if a sub class is created
|
c s> |D ]&}t |trt|j d|j dqt | |||¡S )Nr2 z does not support subclassing)r rT r r0 r ÚsuperÚ__new__)r7 rC ÚbasesZ cls_namespaceÚbase©r r r rV s
|
ÿz Final.__new__)r r0 r r1 rV Ú __classcell__r r rY r rT s rT ÚTc s> e Zd ZdZdd Zeje ejejed fdd Z Z
|
S )ÚNoPublicConstructora Metaclass that enforces a class to be final (i.e., subclass not allowed)
|
and ensures a private constructor.
|
|
If a class uses this metaclass like this::
|
|
class SomeClass(metaclass=NoPublicConstructor):
|
pass
|
|
The metaclass will ensure that no sub class can be created, and that no instance
|
can be initialized.
|
|
If you try to instantiate your class (SomeClass()), a TypeError will be thrown.
|
|
Raises
|
------
|
- TypeError if a sub class or an instance is created.
|
c O s t | j d| j dd S )Nr2 z has no public constructor)r r0 r ©r7 r# rQ r r r rR > s ÿz NoPublicConstructor.__call__)r7 r# rQ Úreturnc s t j||S r )rU rR r] rY r r Ú_createC s zNoPublicConstructor._create) r r0 r r1 rR ÚtÚTyper[ ÚAnyr_ rZ r r rY r r\ + s r\ c C s t | dst| S z| jjd }W n& ttfk
|
rH d | jj¡}Y nX z
|
| j }W n tk
|
rp | jj
|
}Y nX | d| S )z{Return the fully-qualified name of the async generator function
|
that produced the async generator iterator *agen*.
|
Úag_coder z<{}>r2 ) r> ÚreprÚag_frameÚ f_globalsÚAttributeErrorÚKeyErrorr" rc Ú co_filenamer Úco_name)ZagenÚmodulerB r r r Ú name_asyncgenG s
|
|
rl )$r r Úosr ÚsysÚpathlibÚ functoolsr r Útypingr` r
|
r Úasync_generatorr r- rC ZcffiZFFIZ_ffiZcdefZdlopenZ_libr r r r% r& r: rM rN rT ÚTypeVarr[ r\ rl r r r r Ú<module> s6
|
$
|
|
Q
|
|
