>/ilUddlmZdZddlZddlmZddlmZddlm Z m Z m Z m Z m Z mZddlmZdd lmZdd lmZe d Ze d Zdd ZddZddZe eddGddZddZeZded<Gddej<ZGdde eZ Gdde eZ!y) ) annotations)EventLoopToken RunvarTokenRunVar checkpointcheckpoint_if_cancelledcancel_shielded_checkpoint current_tokenN) dataclass) TracebackType)AnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend) AsyncBackendTDcPKtjd{y7w)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)rrD/srv/sistema/bot/venv/lib/python3.12/site-packages/anyio/lowlevel.pyrrs   ( ( *** &$&cPKtjd{y7w)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*s   5 5 777rcPKtjd{y7w)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 6s   8 8 :::rTF)frozenreprc&eZdZUdZded<ded<y)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__rrrrrFs &%rrcNt}|j}t||S)z Return a token object that can be used to call code in the current event loop from another thread. .. versionadded:: 4.11.0 )rr r)r# raw_tokens rr r Ss'&'M++-I - 33rz1WeakKeyDictionary[object, dict[RunVar[Any], Any]] _run_varsc.eZdZejZy) _NoValueSetN)r&r'r(enumauto NO_VALUE_SETrrrr/r/cs499;Lrr/c8eZdZdZddZddZ ddZy) r_var_value _redeemedc.||_||_d|_y)NFr4)selfvarvalues r__init__zRunvarToken.__init__js =B rc|SNrr9s r __enter__zRunvarToken.__enter__os rc:|jj|yr>)r5reset)r9exc_typeexc_valexc_tbs r__exit__zRunvarToken.__exit__rs rN)r:z RunVar[T]r;%T | Literal[_NoValueSet.NO_VALUE_SET])returnRunvarToken[T])rCztype[BaseException] | NonerDzBaseException | NonerEzTracebackType | NonerHNone)r&r'r( __slots__r<r@rFrrrrrgs<-I ,&%   rrceZdZUdZdZej Zded<ef ddZe ddZ e ddZ e ddZ ef dd Z dd Z dd Zdd Zy )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]r2c ||_||_yr>rM)r9namedefaults rr<zRunVar.__init__s  rcvtj} t|S#t$rix}t|<|cYSwxYwr>)r r%r-KeyError)r9r%run_varss r _current_varszRunVar._current_varssB$33  \* * 13 3Hy.O s 88cyr>rr9rRs rgetz RunVar.gets(+rcyr>rr?s rrYz RunVar.getsrc |j|S#t$rC|tjur|cYS|jtjur|jcYSYnwxYwt d|j d)NzRun variable "z!" has no value and no default set)rVrTrr2rO LookupErrorrNrXs rrYz RunVar.gets{ %%%d+ + %f111f&9&99}}$: % TZZL(I J  sA(AAc||j}t||j|tj}|||<|Sr>)rVrrYrr2)r9r; current_varstokens rsetz RunVar.sets;)) D,"2"249L9L"MN" T rc4|j|ur td|jr td|jtj ur |j |=d|_y|j|j |<d|_y#t$r Yd|_ywxYw)Nz)This token does not belong to this RunVarz This token has already been usedT)r5 ValueErrorr7r6r/r2rVrT)r9r_s rrBz RunVar.resets ::T !HI I ???@ @ <<;33 3 &&t, (-||D  t $    s B BBc"d|jdS)Nz )rNr?s r__repr__zRunVar.__repr__stzznA..rN)rQstrrRrG)rHzdict[RunVar[T], T])rRrrHT | D)rHr)rRz%D | Literal[_NoValueSet.NO_VALUE_SET]rHrg)r;rrHrI)r_rIrHrJ)rHrf)r&r'r(r)rKr/r2r*r<propertyrVrrYr`rBrerrrrr{s$I6A6N6NL3NKW  "G ++ @L  <     "/rr)rHrJ)rHr)" __future__r__all__r0 dataclassesr typesr typingr rrrrrweakrefr_core._eventlooprabcrrrrrr rr r-r*Enumr/rrrrrrrs"  !BB%/ CL CL + 8 ;  $U#$ 4@Q?R <R$))'!*(H/WQZH/r