91 lines
7.8 KiB
Plaintext
91 lines
7.8 KiB
Plaintext
|
Ë
|
|||
|
|
ïÅÙj& ã ól — U d dl mZ dZd dlZd dlmZ d dlmZ d dlm Z m
|
|||
|
|
Z
|
|||
|
|
m Z m Z m
|
|||
|
|
Z
|
|||
|
|
mZ d dlmZ dd lmZ dd
|
|||
|
|
lmZ e d « Z e d « Zd d
|
|||
|
|
„Zd d„Zd d„Ze
|
|||
|
|
edd¬« G d„ d« « « Zd d„Z e« Z de d< G d„ dej< « Z G d„ de
|
|||
|
|
e « Z G d „ d e
|
|||
|
|
e « Z!y) é )Ú annotations)ÚEventLoopTokenÚ RunvarTokenÚRunVarÚ
|
|||
|
|
checkpointÚcheckpoint_if_cancelledÚcancel_shielded_checkpointÚ
|
|||
|
|
current_tokenN)Ú dataclass)Ú
|
|||
|
|
TracebackType)ÚAnyÚGenericÚLiteralÚTypeVarÚfinalÚoverload)ÚWeakKeyDictionaryé )Úget_async_backend)Ú AsyncBackendÚTÚDc ƒ óP K — t « j « ƒ d{ –—† y7 Œw)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 r © ó úRC:\Users\30997\AppData\Local\Temp\pip-target-6g32zz5s\lib\python\anyio/lowlevel.pyr r s è ø€ ô Ó
|
|||
|
|
×
|
|||
|
|
(Ñ
|
|||
|
|
(Ó
|
|||
|
|
*×*Ò*úó ‚ &ž$Ÿ&c ƒ óP K — t « j « ƒ d{ –—† y7 Œw)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 r r r r r r ) s è ø€ ô Ó
|
|||
|
|
×
|
|||
|
|
5Ñ
|
|||
|
|
5Ó
|
|||
|
|
7×7Ò7úr c ƒ óP K — t « j « ƒ d{ –—† y7 Œw)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 r r r r r r 5 s è ø€ ô Ó
|
|||
|
|
×
|
|||
|
|
8Ñ
|
|||
|
|
8Ó
|
|||
|
|
:×:Ò:úr TF)ÚfrozenÚreprc ó& — e Zd ZU dZded< ded< y)r za
|
|||
|
|
An opaque object that holds a reference to an event loop.
|
|||
|
|
|
|||
|
|
.. versionadded:: 4.11.0
|
|||
|
|
ztype[AsyncBackend]Ú
|
|||
|
|
backend_classÚobjectÚ native_tokenN)Ú__name__Ú
|
|||
|
|
__module__Ú __qualname__Ú__doc__Ú__annotations__r r r r r D s … ñð &Ó%ØÔr r c óN — t « } | j « }t | |« S )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 r
|
|||
|
|
r )r# Ú raw_tokens r r
|
|||
|
|
r
|
|||
|
|
Q s' € ô &Ó'€MØ ×+Ñ+Ó-€IÜ ˜-¨Ó 3Ð3r z1WeakKeyDictionary[object, dict[RunVar[Any], Any]]Ú _run_varsc ó. — e Zd Z ej « Zy)Ú _NoValueSetN)r& r' r( ÚenumÚautoÚ NO_VALUE_SETr r r r/ r/ d s „ Ø �4—9‘9“;�Lr r/ c ó8 — e Zd ZdZdd„Zdd„Z dd„Zy) r ©Ú_varÚ_valueÚ _redeemedc ó. — || _ || _ d| _ y )NFr4 )ÚselfÚvarÚvalues r Ú__init__zRunvarToken.__init__k s € ؈Œ Ø=BˆŒ Ø ˆ�r c ó — | S ©Nr ©r9 s r Ú __enter__zRunvarToken.__enter__p s € ؈ r c ó: — | j j | « y r> )r5 Úreset)r9 Úexc_typeÚexc_valÚexc_tbs r Ú__exit__zRunvarToken.__exit__s s € ð
|
|||
|
|
� ‰ �‰˜Õ r N)r: z RunVar[T]r; ú%T | Literal[_NoValueSet.NO_VALUE_SET])ÚreturnúRunvarToken[T])rC ztype[BaseException] | NonerD zBaseException | NonerE zTracebackType | NonerH ÚNone)r& r' r( Ú __slots__r< r@ rF r r r r r h s< „ Ø-€Ió ó
|
|||
|
|
ð à,ð ð &ð ð %ð ð
|
|||
|
|
|
|||
|
|
ô r r c óª — e Zd ZU dZdZej Zded< ef dd„Ze dd„« Z
|
|||
|
|
e dd„« Z e dd„« Z ef dd „Z dd
|
|||
|
|
„Z
|
|||
|
|
dd „Zdd „Zy
|
|||
|
|
)r a
|
|||
|
|
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]r2 c ó — || _ || _ y r> rM )r9 ÚnameÚdefaults r r< zRunVar.__init__ˆ s € 𠈌
|
|||
|
|
Ø ˆ�
|
|||
|
|
r c óv — t « j } t | S # t $ r i x}t |< |cY S w xY wr> )r
|
|||
|
|
r% r- ÚKeyError)r9 r% Úrun_varss r Ú
|
|||
|
|
_current_varszRunVar._current_varsŽ sB € ä$“×3Ñ3ˆ ð Ü ˜\Ñ*Ð *øÜò Ø13Ð 3ˆH”y Ñ.ØŠOð ús – Ÿ8·8c ó — y r> r ©r9 rR s r Úgetz
|
|||
|
|
RunVar.get— s € Ø(+r c ó — y r> r r? s r rY z
|
|||
|
|
RunVar.getš s € Ør c óò — | j | S # t $ rC |t j ur|cY S | j t j ur| j cY S Y nw xY wt d| j › d�« ‚)NzRun variable "z!" has no value and no default set)rV rT r r2 rO Ú LookupErrorrN rX s r rY z
|
|||
|
|
RunVar.get� s{ € ð %Ø×%Ñ% dÑ+Ð +øÜò %Øœf× 1Ñ 1Ñ1Ø ’Ø— ‘ ¤f×&9Ñ&9Ñ9Ø—}‘}Ò$ñ :ð %úô Ø ˜TŸZ™Z˜LÐ(IÐ Jó
|