+ Xja0t$^RIHtR t^RIt^RIHt^RIHt^RI H t H t H t H t HtHtHt^R IHt^R IHt] 'd^R IHt]!R 4t]!R 4tRRltRRltRRlt]]!RRR7!RR444tRRlt]!4tR]R&!RR]P@4t!!RR] ],4t"!RR] ],4t#R#)!) annotationsEventLoopToken RunvarTokenRunVarN) dataclass) TracebackType) TYPE_CHECKINGAnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend) AsyncBackendTDcV^8dQhRR/#returnNone)formats"j/Users/wind/Downloads/Coruna-main学习资料A/backend/venv/lib/python3.14/site-packages/anyio/lowlevel.py __annotate__rs + +$ +cR"\4P4GRjxL R#L5i)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)r checkpointrrrr r s   ( ( *** '%'cV^8dQhRR/#rr)rs"rrr+s 8 8t 8rcR"\4P4GRjxL R#L5i)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)rcheckpoint_if_cancelledrrrr$r$+s   5 5 777r!cV^8dQhRR/#rr)rs"rrr7s ; ;$ ;rcR"\4P4GRjxL R#L5i)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)rcancel_shielded_checkpointrrrr'r'7s   8 8 :::r!TF)frozenreprc0]tRt^Ft$RtR]R&R]R&RtR#)rzU 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 &%rcV^8dQhRR/#)rrrr)rs"rrrSs 4 4~ 4rcL\4pVP4p\W4#)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 )r current_tokenr)r+ raw_tokens rr7r7Ss%&'M++-I - 33rz1WeakKeyDictionary[object, dict[RunVar[Any], Any]] _run_varsc8]tRt^ft]P !4tRtR#) _NoValueSetrN)r.r/r0r1enumauto NO_VALUE_SETr4rrrr;r;fs 99;Lrr;cB]tRt^jtRtR tRRltRRltRRltRt R #) 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`. c V^8dQhRRRR/#)rvarz RunVar[T]value%T | Literal[_NoValueSet.NO_VALUE_SET]r)rs"rrRunvarToken.__annotate__tsI.Src ,WnW nRVnR#)FN_var_value _redeemed)selfrArBs&&&r__init__RunvarToken.__init__ts =B rcV^8dQhRR/#)rrRunvarToken[T]r)rs"rrrDys>rc V#NrrJs&r __enter__RunvarToken.__enter__ys rc(V^8dQhRRRRRRRR/#) rexc_typeztype[BaseException] | Noneexc_valzBaseException | Noneexc_tbzTracebackType | Nonerrr)rs"rrrD|s2,&%   rc <VPPV4R#rP)rGreset)rJrUrVrWs&&&&r__exit__RunvarToken.__exit__|s r)rIrHrGNrF) r.r/r0r1r2 __slots__rKrRrZr4rrrrrjs".I rc]tRt^t$RtRt]PtR]R&]3RRllt ] RRl4t ] RR l4t ] R R l4t ]3R R llt RRltRRltRRltRtR#)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. z!Literal[_NoValueSet.NO_VALUE_SET]r>c V^8dQhRRRR/#)rnamestrdefaultrCr)rs"rrRunVar.__annotate__s   "G rc WnW nR#rP_name_default)rJr_ras&&&rrKRunVar.__init__s  rcV^8dQhRR/#)rrzdict[RunVar[T], T]r)rs"rrrbs1rc \4Pp\V,# \d/;p\T&Tu#i;irP)r7r-r9KeyError)rJr-run_varss& r _current_varsRunVar._current_varssB$33  \* * 13 3Hy.O s #>>c V^8dQhRRRR/#)rrarrT | Dr)rs"rrrbs++1++rc R#rPrrJras&&rget RunVar.gets(+rcV^8dQhRR/#)rrrr)rs"rrrbs Qrc R#rPrrQs&rrrrssrc V^8dQhRRRR/#)rraz%D | Literal[_NoValueSet.NO_VALUE_SET]rror)rs"rrrbs  <  rc VPV,# \dHT\PJdTu#TP\PJdTPu#Mi;i\ RTP R24h)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)rlrjrr>rf LookupErrorrerqs&&rrrrss{ %%%d+ + %f111f&9&99}}$: % TZZL(I J  s!A'*A'&A'c V^8dQhRRRR/#)rrBrrrNr)rs"rrrbs   ~ rc xVPp\WPV\P44pWV&V#)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 )rlrrrrr>)rJrB current_varstokens&& rset RunVar.sets9)) D"2"249L9L"MN"T rc V^8dQhRRRR/#)rr|rNrrr)rs"rrrbs>drc 2VPVJd \R4hVP'd \R4hVP\P JdVP VMVPVP V&RVnR# \dLi;i)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)rG ValueErrorrIrHr;r>rlrj)rJr|s&&rrY RunVar.resets ::T !HI I ????@ @ <<;33 3 &&t,(-||D  t $   s B BBcV^8dQhRR/#)rrr`r)rs"rrrbs//#/rc $RVP: R2#)z )rerQs&r__repr__RunVar.__repr__stzznA..r)rfreNrd)r.r/r0r1r2r\r;r>r3rKpropertyrlrrrr}rYrr4rrrrrs}$I6A6N6NL3NKW ++ @L . 2//r)rrrr r$r'r7)$__conditional_annotations__ __future__r__all__r< dataclassesrtypesrtypingr r r r r rrweakrefr_core._eventlooprabcrrrr r$r'rr7r9r3Enumr;rr)rs@rrs""  !QQQ%/! CL CL + 8 ; $U#$ 4 @Q?R <R$))'!*6_/WQZ_/r