_jUddlmZdZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZmZddlmZdd lmZe rdd lmZe d Ze d Zd dZd dZd dZeeddGddZd!dZeZded<GddejZ Gdde eZ!Gdde eZ"dS)") annotations)EventLoopToken RunvarTokenRunVar checkpointcheckpoint_if_cancelledcancel_shielded_checkpoint current_tokenN) dataclass) TracebackType) TYPE_CHECKINGAnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend) AsyncBackendTDreturnNonecVKtd{VdS)z Check for cancellation and allow the scheduler to switch to another task. Equivalent to (but more efficient than):: await checkpoint_if_cancelled() await cancel_shielded_checkpoint() .. versionadded:: 3.0 N)rrB/home/drrone/.local/lib/python3.11/site-packages/anyio/lowlevel.pyrrs8    ( ( * **********rcVKtd{VdS)z Enter a checkpoint if the enclosing cancel scope has been cancelled. This does not allow the scheduler to switch to a different task. .. versionadded:: 3.0 N)rrrrrrr+s8    5 5 7 7777777777rcVKtd{VdS)z Allow the scheduler to switch to another task but without checking for cancellation. Equivalent to (but potentially more efficient than):: with CancelScope(shield=True): await checkpoint() .. versionadded:: 3.0 N)rr rrrr r 7s8    8 8 : ::::::::::rTF)frozenreprc(eZdZUdZded<ded<dS)rza An opaque object that holds a reference to an event loop. .. versionadded:: 4.11.0 ztype[AsyncBackend] backend_classobject native_tokenN)__name__ __module__ __qualname____doc____annotations__rrrrrFs6 &%%%rrcft}|}t||S)z Return a token object that can be used to call code in the current event loop from another thread. :raises NoEventLoopError: if no supported asynchronous event loop is running in the current thread .. versionadded:: 4.11.0 )rr r)r% raw_tokens rr r Ss0&''M++--I - 3 33rz1WeakKeyDictionary[object, dict[RunVar[Any], Any]] _run_varsc,eZdZejZdS) _NoValueSetN)r(r)r*enumauto NO_VALUE_SETrrrr1r1fs49;;LLLrr1c.eZdZdZdZddZdd ZddZdS)rz A token that can be used to restore a :class:`RunVar` to its previous value. Returned by :meth:`RunVar.set`. Can be used as a context manager to automatically reset the variable on exit, or passed directly to :meth:`RunVar.reset`. _var_value _redeemedvar RunVar[T]value%T | Literal[_NoValueSet.NO_VALUE_SET]c0||_||_d|_dS)NFr6)selfr:r<s r__init__zRunvarToken.__init__ts =B rrRunvarToken[T]c|SNrr?s r __enter__zRunvarToken.__enter__ys rexc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbTracebackType | Nonerc:|j|dSrC)r7reset)r?rFrHrJs r__exit__zRunvarToken.__exit__|s rN)r:r;r<r=)rrA)rFrGrHrIrJrKrr)r(r)r*r+ __slots__r@rErNrrrrrjsa.I rrceZdZUdZdZejZded<efdd Ze dd Z e ddZ e ddZ efd dZ d!dZ d"dZd#dZdS)$ra Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop. Can be used as a context manager, Just like :class:`~contextvars.ContextVar`, that will reset the variable to its previous value when the context block is exited. _name_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r4namestrdefaultr=c"||_||_dSrCrQ)r?rTrVs rr@zRunVar.__init__s  rrdict[RunVar[T], T]ctj} t|S#t$rix}t|<|cYSwxYwrC)r r'r/KeyError)r?r'run_varss r _current_varszRunVar._current_varssQ$3  \* *   13 3Hy.OOO s "==rT | DcdSrCrr?rVs rgetz RunVar.gets(+rrcdSrCrrDs rr`z RunVar.getsr%D | Literal[_NoValueSet.NO_VALUE_SET]c |j|S#t$r1|tjur|cYS|jtjur |jcYSYnwxYwt d|jd)a2 Return the current value of this run variable. :param default: a fallback value to return if no value has been set :return: the current value, the provided default, or the variable's own default :raises LookupError: if no value is set and no default is available zRun variable "z!" has no value and no default set)r\rZrr4rS LookupErrorrRr_s rr`z RunVar.gets %%d+ + % % %f111f&999}$$$:9 %  JTZ J J J   s A A  A r<rAcz|j}t|||tj}|||<|S)z Set the value of this run variable for the current event loop. :param value: the new value :return: a token that can be used to restore the previous value )r\rr`rr4)r?r< current_varstokens rsetz RunVar.sets=) D,"2"249L"M"MNN" T rrgrc|j|urtd|jrtd|jtjur |j|=n#t$rYnwxYw|j|j|<d|_dS)a Restore this run variable to the value it held before the matching :meth:`set`. :param token: the token returned by :meth:`set` :raises ValueError: if the token belongs to a different :class:`RunVar` or the token has already been used z)This token does not belong to this RunVarz This token has already been usedTN)r7 ValueErrorr9r8r1r4r\rZ)r?rgs rrMz RunVar.resets :T ! !HII I ? A?@@ @ <;3 3 3 &t,,    (-|D t $sA AAcd|jdS)Nz )rRrDs r__repr__zRunVar.__repr__s.tz....rN)rTrUrVr=)rrX)rVrrr])rr)rVrbrr])r<rrrA)rgrArr)rrU)r(r)r*r+rOr1r4r,r@propertyr\rr`rhrMrmrrrrrs$I6A6NLNNNNKW     X+++X+ X@L     .    2//////rr)rr)rr)# __future__r__all__r2 dataclassesr typesr typingr rrrrrrweakrefr_core._eventlooprabcrrrrrr rr r/r,Enumr1rrrrrrxs6"""""""  !!!!!!QQQQQQQQQQQQQQQQQQ%%%%%%//////"!!!!!! GCLL GCLL + + + + 8 8 8 8 ; ; ; ; $U###$# 4 4 4 4 @Q?P?R?R RRRR$)'!*6_/_/_/_/_/WQZ_/_/_/_/_/r