Files
aitsc/.venv/Lib/site-packages/anyio/__pycache__/lowlevel.cpython-312.pyc

75 lines
6.8 KiB
Plaintext
Raw Normal View History

2025-02-23 09:07:52 +08:00
<EFBFBD>
q&<26>h<EFBFBD><00><01>N<00>UddlmZddlZddlmZddlmZmZmZm Z m
2025-02-23 09:07:52 +08:00
Z
ddl m Z ddl mZe d<08>Ze d <09>Zdd
<EFBFBD>Zdd <0B>Zdd <0C>Zdd <0A>Ze <0C>Zded<iZded<ed<12><13>Gd<14>d<15><00>ZGd<16>dej2<00>ZGd<18>dee<00>ZGd<1A>dee<00>Zy)<1E>)<01> annotationsN)<01> dataclass)<05>Any<6E>Generic<69>Literal<61>TypeVar<61>overload)<01>WeakKeyDictionary<72>)<01>get_async_backend<6E>T<>Dc<00><01>PK<00>t<00>j<00><00>d{<00><02><03>y7<00><05>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 <00>
checkpoint<EFBFBD><00><00>7D:\xxxx\aitsc\.venv\Lib\site-packages\anyio\lowlevel.pyrrs<00><00><><00> <1C>
2025-02-23 09:07:52 +08:00
<1D>
(<28>
(<28>
*<2A>*<2A>*<2A><> <00>&<01>$<04>&c<00><01>PK<00>t<00>j<00><00>d{<00><02><03>y7<00><05>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 <00>checkpoint_if_cancelledrrrrrs<00><00><><00> <1C>
<1D>
5<EFBFBD>
5<EFBFBD>
7<EFBFBD>7<>7<>rc<00><01>PK<00>t<00>j<00><00>d{<00><02><03>y7<00><05>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 <00>cancel_shielded_checkpointrrrrr*s<00><00><><00> <1C>
<1D>
8<EFBFBD>
8<EFBFBD>
:<3A>:<3A>:<3A>rc<01>2<00>t<00>j<00>S)ze
Return a backend specific token object that can be used to get back to the event
loop.
)r <00> current_tokenrrrrr:s<00><00> <1D> <1E> ,<2C> ,<2C> .<2E>.rz&WeakKeyDictionary[Any, dict[str, Any]]<5D> _run_varszdict[Any, _TokenWrapper]<5D>_token_wrappersT)<01>frozenc<01><00>eZdZUdZded<y)<05> _TokenWrapper)<02>_token<65> __weakref__<5F>objectr N)<05>__name__<5F>
__module__<EFBFBD> __qualname__<5F> __slots__<5F>__annotations__rrrrrGs <00><00>'<27>I<EFBFBD> <12>Nrrc<01>.<00>eZdZej<00>Zy)<02> _NoValueSetN)r#r$r%<00>enum<75>auto<74> NO_VALUE_SETrrrr)r)Ms<00><00><1C>4<EFBFBD>9<EFBFBD>9<EFBFBD>;<3B>Lrr)c<01><00>eZdZdZdd<02>Zy)<05> RunvarToken<65><03>_var<61>_value<75> _redeemedc<01>.<00>||_||_d|_y)NFr/)<03>self<6C>var<61>values r<00>__init__zRunvarToken.__init__Ts<00><00><17><04> <09>=B<><04> <0B><1E><04>rN)r5z RunVar[T]r6<00>%T | Literal[_NoValueSet.NO_VALUE_SET])r#r$r%r&r7rrrr.r.Qs <00><00>-<2D>I<EFBFBD>rr.c<01><><00>eZdZUdZdZej Zded<e<08>Z ded<ef dd<07>Z
e dd<08><04>Z e dd <09><04>Ze dd
<EFBFBD><04>Zef dd <0B>Zdd <0C>Zdd <0A>Zdd<0E>Zy)<18>RunVarz[
Like a :class:`~contextvars.ContextVar`, except scoped to the running event loop.
<20><02>_name<6D>_defaultz!Literal[_NoValueSet.NO_VALUE_SET]r,zset[_TokenWrapper]rc<01> <00>||_||_y<00>Nr;)r4<00>name<6D>defaults rr7zRunVar.__init__es<00><00><1A><04>
<EFBFBD><1F><04> rc<01>b<00>t<00>} t|S#t$rix}t|<|cYSwxYwr?)rr<00>KeyError)r4<00>token<65>run_varss r<00> _current_varszRunVar._current_varsks<<00><00><1D><0F><05> <1C><1C>U<EFBFBD>#<23> #<23><><17> <1C>*,<2C> ,<2C>H<EFBFBD>y<EFBFBD><15>'<27><1B>O<EFBFBD> <1C>s <00><00>.<03>.c<01><00>yr?r<00>r4rAs r<00>getz
RunVar.getts<00><00>(+rc<01><00>yr?r<00>r4s rrIz
RunVar.getws<00><00>rc<01><00> |j|jS#t$rC|tjur|cYS|j
tjur|j
cYSYnwxYwt d|j<00>d<02><03><00>)NzRun variable "z!" has no value and no default set)rFr<rCr:r,r=<00> LookupErrorrHs rrIz
RunVar.getzs<00><00> %<25><17>%<25>%<25>d<EFBFBD>j<EFBFBD>j<EFBFBD>1<> 1<><31><17> %<25><16>f<EFBFBD>1<>1<>1<><1E><0E><15><1D><1D>f<EFBFBD>&9<>&9<>9<><1B>}<7D>}<7D>$<24>:<3A> %<25><> <1A><1C>T<EFBFBD>Z<EFBFBD>Z<EFBFBD>L<EFBFBD>(I<> J<>
<EFBFBD>
s<00><00>A'<03>(A'<03>&A'c<01><><00>|j}t||j|jtj
<00><00>}|||j<|Sr?)rFr.rIr<r:r,)r4r6<00> current_varsrDs r<00>setz
RunVar.set<65>sC<00><00><1B>)<29>)<29> <0C><1B>D<EFBFBD>,<2C>"2<>"2<>4<EFBFBD>:<3A>:<3A>v<EFBFBD>?R<>?R<>"S<>T<><05>#(<28> <0C>T<EFBFBD>Z<EFBFBD>Z<EFBFBD> <20><14> rc<01>\<00>|j|ur td<01><00>|jr td<02><00>|jtj
ur |j |j=d|_y|j|j |j<d|_y#t$r
Yd|_ywxYw)Nz)This token does not belong to this RunVarz This token has already been usedT) r0<00>
ValueErrorr2r1r)r,rFr<rC)r4rDs r<00>resetz RunVar.reset<65>s<><00><00> <10>:<3A>:<3A>T<EFBFBD> !<21><1C>H<>I<> I<> <10>?<3F>?<3F><1C>?<3F>@<40> @<40> <10><<3C><<3C>;<3B>3<>3<> 3<> <15><18>&<26>&<26>t<EFBFBD>z<EFBFBD>z<EFBFBD>2<> <1F><05><0F>.3<EFBFBD>\<5C>\<5C>D<EFBFBD> <1E> <1E>t<EFBFBD>z<EFBFBD>z<EFBFBD> *<2A><1E><05><0F><> <1C> <15><14><1F><05><0F>  <15>s<00>B<00> B+<03>*B+c<01>"<00>d|j<00>d<02>S)Nz <RunVar name=<3D>>)r<rKs r<00>__repr__zRunVar.__repr__<5F>s<00><00><1E>t<EFBFBD>z<EFBFBD>z<EFBFBD>n<EFBFBD>A<EFBFBD>.<2E>.rN)r@<00>strrAr8)<02>returnz dict[str, T])rArrX<00>T | D)rXr )rAz%D | Literal[_NoValueSet.NO_VALUE_SET]rXrY)r6r rX<00>RunvarToken[T])rDrZrX<00>None)rXrW)r#r$r%<00>__doc__r&r)r,r'rPrr7<00>propertyrFr rIrSrVrrrr:r:Zs<><00><00><08>$<24>I<EFBFBD>6A<36>6N<36>6N<36>L<EFBFBD>3<>N<>*-<2D>%<25>O<EFBFBD>'<27>/<2F>KW<01> <20><17> <20>"G<> <20> <0E><1C><0E><1C><0E>+<2B><0E>+<2B> <0A><1B><0E><1B>@L<01> 
<EFBFBD><<3C> 
<EFBFBD> <0E> 
<EFBFBD><15> <1F>"/rr:)rXr[)rXr")<1D>
__future__rr*<00> dataclassesr<00>typingrrrrr <00>weakrefr
<00>_core._eventloopr r rrrrrrr'rr<00>Enumr)r.r:rrr<00><module>rds<><00><01>"<22> <0B>!<21>;<3B>;<3B>%<25>/<2F> <0B>C<EFBFBD>L<EFBFBD><01> <0B>C<EFBFBD>L<EFBFBD><01> +<2B> 8<> ;<3B> /<2F>5F<01>4G<34> <09> 1<>G<>,.<2E><0F>)<29>.<2E> <0B>$<24><17><13><13><18><13>
<1F>$<24>)<29>)<29><1F><1F>'<27>!<21>*<2A><1F>G/<2F>W<EFBFBD>Q<EFBFBD>Z<EFBFBD>G/r