o Oh'@s&UddlmZddlZddlZddlmZddlmZmZm Z m Z ddl m Z ddl mZejdkr9dd lmZndd lmZe d Ze d Zd%ddZd%ddZd%ddZd&ddZe Zded<iZded<eddGdddZGdd d ejZGd!d"d"eeZGd#d$d$eeZdS)') annotationsN) dataclass)AnyGenericTypeVaroverload)WeakKeyDictionary) get_asynclib))LiteralTDreturnNonectIdHdS)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 checkpointrr[/var/www/html/HyperOracle/crypto_trader/venv/lib/python3.10/site-packages/anyio/lowlevel.pyr rcr)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)r checkpoint_if_cancelledrrrrr$s rcr)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)r cancel_shielded_checkpointrrrrr0rrobjectcCs tS)zVReturn a backend specific token object that can be used to get back to the event loop.)r current_tokenrrrrr@s rz&WeakKeyDictionary[Any, dict[str, Any]] _run_varszdict[Any, _TokenWrapper]_token_wrappersT)frozenc@seZdZUdZded<dS) _TokenWrapper)_token __weakref__rrN)__name__ __module__ __qualname__ __slots____annotations__rrrrrIs  rc@seZdZeZdS) _NoValueSetN)r!r"r#enumauto NO_VALUE_SETrrrrr&Os r&c@seZdZdZd ddZdS) RunvarToken_var_value _redeemedvar RunVar[T]value%T | Literal[_NoValueSet.NO_VALUE_SET]cCs||_||_d|_dS)NFr+)selfr/r1rrr__init__Vs zRunvarToken.__init__N)r/r0r1r2)r!r"r#r$r4rrrrr*Ssr*c@seZdZUdZdZejZded<eZ ded<efd$d d Z e d%ddZ e d&ddZe d'ddZefd(ddZd)ddZd*dd Zd+d!d"Zd#S),RunVarz[ Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop. _name_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r)zset[_TokenWrapper]rnamestrdefaultr2cCs||_||_dSNr6)r3r9r;rrrr4gs zRunVar.__init__r dict[str, T]cCs\t} zt|WStyt|}|j|Ynty,i}t|<|YSwqr<)rr TypeErrorrraddKeyError)r3tokenrun_varsrrr _current_varsos    zRunVar._current_varsrT | DcCdSr<rr3r;rrrgetz RunVar.getrcCrEr<rr3rrrrGrH%D | Literal[_NoValueSet.NO_VALUE_SET]cCs\z|j|jWSty$|tjur|YS|jtjur"|jYSYnwtd|jd)NzRun variable "z!" has no value and no default set)rCr7r@r5r)r8 LookupErrorrFrrrrGs     r1RunvarToken[T]cCs*|j}t|||jtj}|||j<|Sr<)rCr*rGr7r5r))r3r1 current_varsrArrrsets z RunVar.setrArcCsf|j|ur td|jrtd|jtjur'z|j|j=Wnty&Ynw|j|j|j<d|_dS)Nz)This token does not belong to this RunVarz This token has already been usedT) r, ValueErrorr.r-r&r)rCr7r@)r3rArrrresets    z RunVar.resetcCsd|jdS)Nz )r7rIrrr__repr__szRunVar.__repr__N)r9r:r;r2)rr=)r;rrrD)rr)r;rJrrD)r1rrrL)rArLrr)rr:)r!r"r#__doc__r$r&r)r%rNrr4propertyrCrrGrPrRrrrrr5\s$       r5)rr)rr) __future__rr'sys dataclassesrtypingrrrrweakrefr_core._eventloopr version_infor typing_extensionsrrrrrrrr%rrEnumr&r*r5rrrrs.