ޠj%SSKJr SrSSKrSSKJr SSKJr SSKJ r J r J r J r J r JrJr SSKJr SS KJr \ (aSS KJr \ "S 5r\ "S 5rSS jrSSjrSSjr\\"SSS9"SS555rSSjr\"5rS\S'"SS\R>5r "SS\ \5r!"SS\ \5r"g) ) annotations)EventLoopTokenRunVar RunvarTokencancel_shielded_checkpoint checkpointcheckpoint_if_cancelled current_tokenN) dataclass) TracebackType) TYPE_CHECKINGAnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend) AsyncBackendTDcP# [5R5IShvN gN7f)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)rrH/var/www/html/gaurav/venv/lib/python3.13/site-packages/anyio/lowlevel.pyrrs   ( ( *** &$&cP# [5R5IShvN gN7f)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)rr rrrr r +s   5 5 777rcP# [5R5IShvN gN7f)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)rrrrrrr7s   8 8 :::rTF)frozenreprc.\rSrSr%SrS\S'S\S'Srg) rFzU An opaque object that holds a reference to an event loop. .. versionadded:: 4.11.0 ztype[AsyncBackend] backend_classobject native_tokenrN)__name__ __module__ __qualname____firstlineno____doc____annotations____static_attributes__rrrrrFs &%rrcL[5nUR5n[X5$)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 Ss%&'M++-I - 33rz1WeakKeyDictionary[object, dict[RunVar[Any], Any]] _run_varsc6\rSrSr\R "5rSrg) _NoValueSetfrN)r(r)r*r+enumauto NO_VALUE_SETr.rrrr3r3fs 99;Lrr3cJ\rSrSrSrSrSSjrS SjrS SjrSr g) rjz 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`. ) _redeemed_value_varc*XlX lSUlg)NF)r<r;r:)selfvarvalues r__init__RunvarToken.__init__ts =B rcU$Nrr>s r __enter__RunvarToken.__enter__ys rc:URRU5 grD)r<reset)r>exc_typeexc_valexc_tbs r__exit__RunvarToken.__exit__|s rN)r?z RunVar[T]r@%T | Literal[_NoValueSet.NO_VALUE_SET])returnRunvarToken[T])rJztype[BaseException] | NonerKzBaseException | NonerLzTracebackType | NonerPNone) r(r)r*r+r, __slots__rArFrMr.rrrrrjsC.I ,&%   rrc\rSrSr%SrSr\RrS\S'\4SSjjr \ SSj5r \ SSj5r \ SS j5r \4SS jjr SS jrSS jrSS jrSrg)rz 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. )_default_namez!Literal[_NoValueSet.NO_VALUE_SET]r7cXlX lgrD)rWrV)r>namedefaults rrARunVar.__init__s  rcx[5Rn[U$![a 0=n[U'Us$f=frD)r r'r1KeyError)r>r'run_varss r _current_varsRunVar._current_varssB$33  \* * 13 3Hy.O s 99cgrDrr>rZs rget RunVar.gets(+rcgrDrrEs rrcrdsrcURU$![aE U[RLaUs$UR[RLaURs$Of=f[ SUR S35e)a  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_r]rr7rV LookupErrorrWrbs rrcrds{ %%%d+ + %f111f&9&99}}$: % TZZL(I J  sA )A A cxURn[XRU[R55nXU'U$)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_rrcrr7)r>r@ current_varstokens rset RunVar.sets9)) D"2"249L9L"MN"T rc(URULa [S5eUR(a [S5eUR[R LaUR U OURUR U'SUlg![a Nf=f)z 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)r< ValueErrorr:r;r3r7r_r])r>rjs rrI RunVar.resets ::T !HI I ???@ @ <<;33 3 &&t,(-||D  t $   s B BBc$SUR<S3$)Nz )rWrEs r__repr__RunVar.__repr__stzznA..rN)rYstrrZrO)rPzdict[RunVar[T], T])rZrrPT | D)rPr)rZz%D | Literal[_NoValueSet.NO_VALUE_SET]rPru)r@rrPrQ)rjrQrPrR)rPrt)r(r)r*r+r,rSr3r7r-rApropertyr_rrcrkrIrrr.rrrrrs$I6A6N6NL3NKW  "G ++ @L <  . 2/rr)rPrR)rPr)# __future__r__all__r5 dataclassesr typesr typingr rrrrrrweakrefr_core._eventlooprabcrrrrr rrr r1r-Enumr3rrrrrrs"  !QQQ%/! CL CL + 8 ; $U#$ 4 @Q?R <R$))'!*6_/WQZ_/r