+ ;O|jca0t$^RIHt^RIt^RIHuHtR t ^RI t ^RI H t ^RI Ht^RIHtHtHtHtHtHtHt^R IHt^R IHt]'d^R IHt]!R 4t]!R 4tRRltRRlt RRlt!]] !RRR7!RR444t"RRlt#]!4t$R]%R&!RR] PL4t'!RR]],4t(!RR]],4t)R#)!) annotationsNEventLoopToken RunvarTokenRunVar) dataclass) TracebackType) TYPE_CHECKINGAnyGenericLiteralTypeVarfinaloverload)WeakKeyDictionary)get_async_backend) AsyncBackendTDcV^8dQhRR/#returnNone)formats"GC:\Users\alokc\chatbot\backend\venv\Lib\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 checkpointrrrrrs   ( ( *** '%'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 rr6r6Ss%&'M++-I - 33rz1WeakKeyDictionary[object, dict[RunVar[Any], Any]] _run_varsc8]tRt^ft]P !4tRtR#) _NoValueSetrN)r-r.r/r0enumauto NO_VALUE_SETr3rrrr: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)selfr@rAs&&&r__init__RunvarToken.__init__ts =B rcV^8dQhRR/#)rrRunvarToken[T]r)rs"rrrCys>rc V#NrrIs&r __enter__RunvarToken.__enter__ys rc(V^8dQhRRRRRRRR/#) rexc_typeztype[BaseException] | Noneexc_valzBaseException | Noneexc_tbzTracebackType | Nonerrr)rs"rrrC|s2,&%   rc <VPPV4R#rO)rFreset)rIrTrUrVs&&&&r__exit__RunvarToken.__exit__|s r)rHrGrFNrE) r-r.r/r0r1 __slots__rJrQrYr3rrrrrjs".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/#)rnamestrdefaultrBr)rs"rrRunVar.__annotate__s   "G rc WnW nR#rO_name_default)rIr^r`s&&&rrJRunVar.__init__s  rcV^8dQhRR/#)rrzdict[RunVar[T], T]r)rs"rrras1rc \4Pp\V,# \d/;p\T&Tu#i;irO)r6r,r8KeyError)rIr,run_varss& r _current_varsRunVar._current_varssB$33  \* * 13 3Hy.O s #>>c V^8dQhRRRR/#)rr`rrT | Dr)rs"rrras++1++rc R#rOrrIr`s&&rget RunVar.gets(+rcV^8dQhRR/#)rrrr)rs"rrras Qrc R#rOrrPs&rrqrrsrc V^8dQhRRRR/#)rr`z%D | Literal[_NoValueSet.NO_VALUE_SET]rrnr)rs"rrras  <  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)rkrirr=re LookupErrorrdrps&&rrqrrs{ %%%d+ + %f111f&9&99}}$: % TZZL(I J  s!A'*A'&A'c V^8dQhRRRR/#)rrArrrMr)rs"rrras   ~ 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 )rkrrqrr=)rIrA current_varstokens&& rset RunVar.sets9)) D"2"249L9L"MN"T rc V^8dQhRRRR/#)rr{rMrrr)rs"rrras>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)rF ValueErrorrHrGr:r=rkri)rIr{s&&rrX RunVar.resets ::T !HI I ????@ @ <<;33 3 &&t,(-||D  t $   s B BBcV^8dQhRR/#)rrr_r)rs"rrras//#/rc $RVP: R2#)z )rdrPs&r__repr__RunVar.__repr__stzznA..r)rerdNrc)r-r.r/r0r1r[r:r=r2rJpropertyrkrrqr|rXrr3rrrrrs}$I6A6N6NL3NKW ++ @L . 2//r)rrrrr#r&r6)*__conditional_annotations__ __future__rbuiltins @py_builtins_pytest.assertion.rewrite assertionrewrite @pytest_ar__all__r; dataclassesrtypesrtypingrr r r r r rweakrefr_core._eventlooprabcrrrrr#r&rr6r8r2Enumr:rr)rs@rrs""  !QQQ%/! CL CL + 8 ; $U#$ 4 @Q?R <R$))'!*6_/WQZ_/r