f8ddlmZddlZddlZddlZddlZddlZddlm Z ddl m Z ddl m Z mZmZmZmZmZmZmZmZddlmZddlZededef Zed Zed Ze r*dd lmZm Z dd l!m"Z"m#Z#m$Z$m%Z%e"dZ&e$dZ'e rdEdZ(nYej)dkrJddl*Z*e*j+Z,e,-de,.dZ/e0e/dZ(ndEdZ(dFdZ1dGd!Z2Gd"d#Z3dHd*Z4dId.Z5Gd/d0eeZ6dJd2Z7dKd5Z8e rdd6l mZne8ZeGd7d8e Z9dLd;Z:e red._return_value_looks_like_wrong_librarywsK e[_6 7 7 4 54d ; ; G4'+AAAr&triozLTrio was expecting an async function, but instead it got a coroutine object z/ Probably you did something like: trio.run(z4(...)) # incorrect! nursery.start_soon(zO(...)) # incorrect! Instead, you want (notice the parentheses!): trio.run(z2, ...) # correct! nursery.start_soon(z, ...) # correct!z9Trio was expecting an async function, but instead it got u – are you trying to use a library written for asyncio/twisted/tornado or similar? That won't work without some sort of compatibility shim.zTrio got unexpected zAstart_soon expected an async function but got an async generator zCTrio expected an async function, but {!r} appears to be synchronous __qualname__)r;r<rr.) sniffio_loopnamer2rArBrC CoroutinecloserGinspect isasyncgenformatrE)r5r7rH prev_loopcoros r$coroutine_or_errorrTss= B B B B$0#4f I| $&x  h  9 : :  NN    N&. N N '/ N N )1(9 N N'/ N N)1(9 N N N    2 1( ; ; ;;;;    = F& I %%%% dKO5 6 6 1 1$ 7 7 KtKKK   d # # &!&&    &>8!L!LMM   Ks%CBB77CCc*eZdZdZddZddZddZdS)ConflictDetectoraDetect 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. msgstrrrc"||_d|_dSNF)_msg_held)selfrWs r$__init__zConflictDetector.__init__s  r&cT|jrtj|jd|_dS)NT)r\rIBusyResourceErrorr[)r]s r$ __enter__zConflictDetector.__enter__s* : (33 3DJJJr&exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | Nonecd|_dSrZ)r\)r]rbrdrfs r$__exit__zConflictDetector.__exit__s  r&N)rWrXrr)rr)rbrcrdrerfrgrr)rG __module__rJ__doc__r^rarir"r&r$rVrVsZ   r&rVcls type[object] wrapped_cls attr_namerXCallable[[CallT], CallT]cdfd }|S)z@Similar to wraps, but for async wrappers of non-async functions.funcrrc|_djf|_djdjdd|_|S)N.z Like :meth:`~z `, but async.)rGjoinrJrjrk)rrrorlrns r$ decoratorzasync_wraps..decoratorsT! HHc&6 %BCCs{'=ss @Xss[dsss  r&)rrrrrr")rlrnrorvs``` r$ async_wrapsrws5 r& module_name namespace$collections.abc.Mapping[str, object]ctd fd |D]'\}d s |(dS) NqualnamerXrLobjr<rrct| vrdS t|t|dd}||dr|_t |dr'd|jvr||_t |dr||_t|tr6|j D]\}}dz|z||dSdSdSdS)Nrjztrio.rGrtrJ) idaddrE startswithrjhasattrrGrJrAtype__dict__items) r|rLr}modro attr_valuefix_onerxobjnameseen_idss r$rz&fixup_module_metadata..fix_ones c77h   F RWWc<.. ?s~~g66?(CNsJ'' 0Cs|,C,C# 3//0'/C$#t$$ N-0\-?-?-A-ANN)IzGGcMI5y*MMMM ??? N NNNr&_)r|rXrLrXr}r<rr)setrr)rxryr}rrrs` @@@r$fixup_module_metadatarsHNNNNNNNNN*"))++ !!#&& + GGWc * * *++r&c*eZdZdZddZdd ZddZdS)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. fnCallable[..., RetT]rrc4t||||_dSr!)r_fn)r]rs r$r^zgeneric_function.__init__2stR   r&r7rkwargsrc|j|i|Sr!)r)r]r7rs r$__call__zgeneric_function.__call__6stx((((r& subscriptr<rc|Sr!r")r]rs r$ __getitem__zgeneric_function.__getitem__9s r&N)rrrr)r7rrrrr)rr<rr)rGrjrJrkr^rrr"r&r$rr!sZ ))))r&rr c@t|jd|jd)z5Raises an exception when a final class is subclassed.rtz does not support subclassingr2rjrJ)rls r$_init_final_clsr=s& s~WW(8WWW X XXr& decoratedtype[T]cRtt|_t|S)a8Decorator that enforces a class to be final (i.e., subclass not allowed). If a class uses this metaclass like this:: @final class SomeClass: pass The metaclass will ensure that no subclass can be created. Raises ------ - TypeError if a subclass is created ) classmethodr__init_subclass__ std_final)rs r$ _final_implrBs""#.o">">I Y  r&)rc,eZdZdZd dZd fd ZxZS)NoPublicConstructoraMetaclass that ensures a private constructor. If a class uses this metaclass like this:: @final class SomeClass(metaclass=NoPublicConstructor): pass The metaclass will ensure that no instance can be initialized. This should always be used with @final. If you try to instantiate your class (SomeClass()), a TypeError will be thrown. Use _create() instead in the class's implementation. Raises ------ - TypeError if an instance is created. r7r<rrrc@t|jd|jd)Nrtz has no public constructorr)rlr7rs r$rzNoPublicConstructor.__call__ss-~ L L 0 L L L   r&rlrrc6tj|i|Sr!)superr)rlr7rrFs r$_createzNoPublicConstructor._createxsuww0000r&)r7r<rr<rr)rlrr7r<rr<rr)rGrjrJrkrr __classcell__)rFs@r$rr^s[&    1111111111r&ragen$AsyncGeneratorType[object, NoReturn]ct|dst|S |jjd}n'#tt f$rd|jjd}YnwxYw |j}n#t$r|jj }YnwxYw|d|S)z{Return the fully-qualified name of the async generator function that produced the async generator iterator *agen*. ag_coderG<>rt) rreprag_frame f_globalsAttributeErrorKeyErrorr co_filenamerJco_name)rmoduler|s r$ name_asyncgenr|s 4 # #Dzz1(4 H %1110T\-0001($ (((<'( ! !x ! !!s!4!AAA$$A=<A=FnwrappedCallable[..., object]assigned Sequence[str]updatedCallable[[Fn], Fn]cdSr!r")rrrs r$wrapsrs !Sr&)r)rrrr)rr.)r5r6r7r8rr9)rlrmrnrmrorXrrp)rxrXryrzrr)rlrmrr )rrrr)rrrrX)..)rrrrrrrr)> __future__rcollections.abcrBrOosr*r,rCr functoolsrtypingrrrr r r r r rrsniffiorrKrIrrrtypesrrtyping_extensionsrrrrrrr%rLcffiFFI_fficdefdlopen_librEr4rTrVrwrrrrrrr<rrr"r&r$rs"""""" $$$$$$                      100000 xS1222 GCLLwv(77777777GGGGGGGGGGGG Ig  E|J''H3;.....W__HKKK 48::DII   ;;: ; ;D74))LL;;;;VVVVrB$++++Dwt}8YYYY     , E11111'111:""""$  Xc6k2 3 3 3B#&!$!!!!!!! r&