python (3.12.0)
͑e r d dl Z d dlZd dlZd dlZd dlmZ d dlmZmZ ed Z ed e
Z G d de Z
ej d d
d Zd Zd
Ze fdZ G d dej& Z G d dej& Z G d dej& Zedk( r ej0 yy) N)
import_module)
gc_collectrequires_working_socketasyncioT)modulec e Zd Zy)AwaitExceptionN__name__
__module__ __qualname__ F/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/test/test_asyncgen.pyr r s r r Fthrowc # " K | rd y d y w)Nr resultr r s r awaitabler s
c d} |rd}| j t }n| j d }|dk( rd}4# t $ r}|j d cY d }~S d }~ww xY w)NFTr r )r r send
StopIterationargs)coroexcfutexs r run_until_completer sf
C
jj 0iio * C 771: s +8 AAAAc . fd}t | S )Nc T K g } 2 3 d { }| j | 7 6 | S wNappend)resigens r iteratezto_list.<locals>.iterate- s3 ! JJqM s
s (%#%(%()r )r( r) s ` r to_listr* , s gi ((r c t j t u r S fd} | S # t $ r t d w xY w)a0 Pure-Python implementation of anext() for testing purposes.
Closely matches the builtin anext() C implementation.
Can be used to compare the built-in implementation of the inner
coroutines machinery to C-implementation of __anext__() and send()
or throw() on the returned generator.
z is not an async iteratorc T K d { S 7 # t $ r cY S w xY wwr# StopAsyncIteration) __anext__defaultiterators r
anext_implz py_anext.<locals>.anext_implG s2 #8,, ,,! N s( ( ( %(%()typer/ AttributeError TypeError _no_default)r1 r0 r2 r/ s `` @r py_anextr7 6 sb BN,, + "" <# B8,&?@AABs 8 Ac * e Zd Zd Zd Zd Zd Zd Zy)AsyncGenSyntaxTestc x d}| j t d 5 t |i i d d d y # 1 sw Y y xY w)NzJasync def foo():
await abc
yield from 123
yield from.*inside asyncassertRaisesRegex SyntaxErrorexecselfcodes r test_async_gen_syntax_01z+AsyncGenSyntaxTest.test_async_gen_syntax_01W =
#
#K1K
L r2 09c x d}| j t d 5 t |i i d d d y # 1 sw Y y xY w)Nz4async def foo():
yield from 123
r; r< r@ s r test_async_gen_syntax_02z+AsyncGenSyntaxTest.test_async_gen_syntax_02` s=
#
#K1K
L r2 rE c x d}| j t d 5 t |i i d d d y # 1 sw Y y xY w)NzXasync def foo():
await abc
yield
return 123
return.*value.*async genr< r@ s r test_async_gen_syntax_03z+AsyncGenSyntaxTest.test_async_gen_syntax_03h =
#
#K1K
L r2 rE c x d}| j t d 5 t |i i d d d y # 1 sw Y y xY w)NzBasync def foo():
yield
return 123
rI r< r@ s r test_async_gen_syntax_04z+AsyncGenSyntaxTest.test_async_gen_syntax_04r rD rE c x d}| j t d 5 t |i i d d d y # 1 sw Y y xY w)NzWasync def foo():
if 0:
yield
return 12
rI r< r@ s r test_async_gen_syntax_05z+AsyncGenSyntaxTest.test_async_gen_syntax_05{ rK rE N)r r r
rC rG rJ rM rO r r r r9 r9 U s r r9 c f e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zy) AsyncGenTestc V d }d } || } || }| j || |S )Nc g } |j | j !# t $ r |j d Y |S t $ r-}|j t t | Y d }~Nd }~ww xY w)NSTOP)r% __next__r Exceptionstrr3 )gr& r s r sync_iteratez5AsyncGenTest.compare_generators.<locals>.sync_iterate so C.JJqzz|, % JJv& J ! .JJs48}--.s % A7A7
#A22A7c g } | j } |j # t $ rJ}|j r#|j |j d Y d }~n[|j d Y d }~nEd }~wt
$ r t $ r-}|j t t | Y d }~nd }~ww xY wn!# t
$ r |j d Y |S w xY w)Nr zEMPTY StopIterationrT ) r/ rU r r r% r. rV rW r3 )rX r& anr s r
async_iteratez6AsyncGenTest.compare_generators.<locals>.async_iterate s C[[]
" KKM - & !ww #
2771: 6 % #
+@ A % 1 " ! ( " JJs48} 5 !" * JJv&J% sT B< ( B< B8*A6B< A61B< 6B8 #B3.B< 3B88B< <CC) assertEqual)rA sync_gen async_genrY r\ sync_gen_resultasync_gen_results r compare_generatorsz AsyncGenTest.compare_generators s:
2 'x0(3 *:; r c T fd} j t | g d y )Nc K t d { d} j | d t d { d t d { d y 7 J7 #7 w)N{ )r assertIs)arA s r r( z5AsyncGenTest.test_async_gen_iteration_01.<locals>.gen sV + A MM!T "+ I+ I
s1 A"A (A"A A"A A" A" A")re rf rg )r] r* rA r( s ` r test_async_gen_iteration_01z(AsyncGenTest.test_async_gen_iteration_01 s
9r c L d } | }|j }|j }| j |j d |j | j d |j }| j |j d |j | j d y # t
$ r)}| j |j d d Y d }~d }~ww xY w# t $ r%}| j |j Y d }~y d }~ww xY w)Nc f K t d { d t d { y 7 7 wNre r r r r r( z5AsyncGenTest.test_async_gen_iteration_02.<locals>.gen s* + I+
s 1-1/11r StopIteration was not raisedr re z!StopAsyncIteration was not raised) __aiter__r/ r] rU failr r r. assertFalserA r( rX air[ r s r test_async_gen_iteration_02z(AsyncGenTest.test_async_gen_iteration_02 s
E
[[]
\\^ 4 6 KKM
II4 5
\\^ 4 ; KKM
II9 : . RWWQZ - - . " & RWW % % &s0 C C5 C2 C--C25 D#>D D#c ~ d }| j t 5 t | d d d y # 1 sw Y y xY w)Nc t K t d { d t d d { d y 7 #7 w)Nre Tr rf ro r r r r( z5AsyncGenTest.test_async_gen_exception_03.<locals>.gen s2 + I$' ' 'I
's 8486 88) assertRaisesr r* rj s r test_async_gen_exception_03z(AsyncGenTest.test_async_gen_exception_03 s5
~
. CEN s 3<c d } | }|j }|j }| j |j d |j | j d | j t 5 |j j d d d y # t
$ r)}| j |j d d Y d }~jd }~ww xY w# 1 sw Y y xY w)Nc H K t d { d ddz y 7 w)Nre r ro r r r r( z5AsyncGenTest.test_async_gen_exception_04.<locals>.gen s" + I
E
s " "r rp r re ) rq r/ r] rU rr r r ry ZeroDivisionErrorrt s r test_async_gen_exception_04z(AsyncGenTest.test_async_gen_exception_04 s
E
[[]
\\^ 4 6 KKM
II4 5
0
1 & LLN # # % & & . RWWQZ - - .
& &s$ B* C * C 3 CC C(c d }| j t d 5 t | d d d y # 1 sw Y y xY w)Nc K d t wrn r- r r r r( z5AsyncGenTest.test_async_gen_exception_05.<locals>.gen s I$ $ z#async generator.*StopAsyncIterationr= RuntimeErrorr* rj s r test_async_gen_exception_05z(AsyncGenTest.test_async_gen_exception_05 s; %
#
#L$IK CEN 4=c d }| j t d 5 t | d d d y # 1 sw Y y xY w)Nc K d t wrn )r r r r r( z5AsyncGenTest.test_async_gen_exception_06.<locals>.gen s I r z async generator.*StopIterationr rj s r test_async_gen_exception_06z(AsyncGenTest.test_async_gen_exception_06 s;
#
#L$DF CEN r c H d }d }| j | | y )Nc 3 R K d ddz d d d y # d d w xY wwNr} r d r r r r r^ z:AsyncGenTest.test_async_gen_exception_07.<locals>.sync_gen 3
AI '
'
$'c ^ K d ddz d d d y # d d w xY wwr r r r r r_ z;AsyncGenTest.test_async_gen_exception_07.<locals>.async_gen s3
AI s -
- *-rb rA r^ r_ s r test_async_gen_exception_07z(AsyncGenTest.test_async_gen_exception_07
s"
IK8r c H d }d }| j | | y )Nc 3 \ K d d ddz d d y # d ddz d w xY wwNr} r r r r r r r r r^ z:AsyncGenTest.test_async_gen_exception_08.<locals>.sync_gen% s:
AI As , ,),c K d t d { t d { d ddz d d y 7 +7 # t d { 7 d ddz d w xY wwr ro r r r r_ z;AsyncGenTest.test_async_gen_exception_08.<locals>.async_gen/ sa
k!! k!!AI "!ik!!AsG A-A AA
A-AA-A A-A*AA**A-r r s r test_async_gen_exception_08z(AsyncGenTest.test_async_gen_exception_08$ "
IK8r c H d }d }| j | | y )Nc 3 R K d ddz d d d y # d d w xY wwr r r r r r^ z:AsyncGenTest.test_async_gen_exception_09.<locals>.sync_gen> r r c K t d { d ddz d t d { d d y 7 07 # d t d { 7 d w xY wwr ro r r r r_ z;AsyncGenTest.test_async_gen_exception_09.<locals>.async_genH s_
k!!A k!!I "
" k!!sG A(
A AA A(AA(A A(A%A A%%A(r r s r test_async_gen_exception_09z(AsyncGenTest.test_async_gen_exception_09= r r c d }| j t d 5 | j j d d d d y # 1 sw Y y xY w)Nc K d y wrn r r r r r( z5AsyncGenTest.test_async_gen_exception_10.<locals>.genW I z!non-None value .* async generatorr )r= r5 r/ r rj s r test_async_gen_exception_10z(AsyncGenTest.test_async_gen_exception_10V sG
#
#I$GI ( EOO " "3 ' ( ( (s %AAc ` d fd}d fd}| j | | y )Nc 3 K d d y wN
r r r r r^ z:AsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen^ s HHs
c 3 K d } | j d | j t d y # t $ r d Y w xY wwNr} r r )r r
GeneratorExit)sgr^ s r sync_gen_wrapperzBAsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen_wrapperb sM GB GGDM
) G !
s% A? A
A AAAc K d d y wr r r r r r_ z;AsyncGenTest.test_async_gen_exception_11.<locals>.async_genl s HHr c K d } | j d d { | j t d { d y 7 ,7 # t $ r d Y w xY wwr )asendathrowr )asgr_ s r async_gen_wrapperzCAsyncGenTest.test_async_gen_exception_11.<locals>.async_gen_wrapperp s` G+C))D/ ! !
jj 111 G
"1
sD !A)AA) A AA A)A A&#A)%A&&A)r )rA r r r_ r^ s @@r test_async_gen_exception_11z(AsyncGenTest.test_async_gen_exception_11] s1
0 24E4GHr c fd} | j }|j }| j t d 5 |j d d d y # 1 sw Y y xY w)Nc B K t d { d y 7
wrn anext)mes r r( z5AsyncGenTest.test_async_gen_exception_12.<locals>.gen} s )OOI
s z4anext\(\): asynchronous generator is already running)rq r/ r= r rU )rA r( ru r[ r s @r test_async_gen_exception_12z(AsyncGenTest.test_async_gen_exception_12| sY U
\\^
\\^
#
#LGI KKM s A A'c d }| j t 5 | j t t d d d d y # 1 sw Y y xY w)Nc K d y wrn r r r r r( zBAsyncGenTest.test_async_gen_3_arg_deprecation_warning.<locals>.gen r r ) assertWarnsDeprecationWarningr r rj s r (test_async_gen_3_arg_deprecation_warningz5AsyncGenTest.test_async_gen_3_arg_deprecation_warning sA
0
1 ? ELL
> ? ? ?s %AAc d } | }| j |j d d|_ | j |j d | j d|j d|_ | j |j d | j |j
| j
|j t j | j |j | j
|j t j | j t j |j# y )Nc K d y wrn r r r r r( z/AsyncGenTest.test_async_gen_api_01.<locals>.gen r r r( 123z.gen)r] r assertInr
assertIsNoneag_awaitassertIsInstanceag_frametypes FrameTypers
ag_runningag_codeCodeType
assertTrueinspect isawaitableaclose)rA r( rX s r test_async_gen_api_01z"AsyncGenTest.test_async_gen_api_01 s
E U+
U+
fann- / !**% ajj%//: & aii 8 ++AHHJ78r N)r r r
rb rk rv rz r r r r r r r r r r r r r r rQ rQ sO ) V
:;:&*9.9292( I> ?9r rQ c P e Zd Zd Zd Zd Zd Zd Zd Zd Z d Z
d Z d
Z d Z
d Zd
Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Zd Z d Z d Z d Z d Z d Z!d Z"d! Z#d" Z$d# Z%d$ Z&d% Z'd& Z(d' Z)d( Z*d) Z+d* Z,d+ Z-d, Z.d- Z/d. Z0d/ Z1d0 Z2d1 Z3d2 Z4d3 Z5d4 Z6d5 Z7d6 Z8y7)8AsyncGenAsyncioTestc ` t j | _ t j d y r# )r new_event_looploopset_event_looprA s r setUpzAsyncGenAsyncioTest.setUp s **, t$r c p | j j d | _ t j d y r# )r closer set_event_loop_policyr s r tearDownz AsyncGenAsyncioTest.tearDown s% %%d+r c | j d 5 | j |t d d d | j d 5 | j |t d d d y # 1 sw Y ;xY w# 1 sw Y y xY w)Nz pure-Pythonr builtin)subTest_check_async_iterator_anextr7 r )rA ait_classs r check_async_iterator_anextz.AsyncGenAsyncioTest.check_async_iterator_anext sq
\\
\
. B , ,Y A B
\\ \
* ? , ,Y > ? ? B B ? ?s A$A0$A-0A9c " fd} j j | } j |g d j t 5 j j | d d d fd} j j | } j |d fd} | fd} j j | } j |d y # 1 sw Y xY w)Nc K g } | j d { | j d { | j d d { | S 7 I7 ,7 w)Nbuckle my shoer$ )resultsr rX s r consumez@AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.consume sY G NNq> * NNq> * NNq*:!;; <N *);s1 A,A& A,A( A,A* A,(A,*A,)r} r r c K } j | d { d j | d { d j t 5 | d { d d d j t 5 | d { d d d }j |d d { d j |d d { d j |d d { d j |d d { d y7 7 7 # 1 sw Y xY w7 # 1 sw Y xY w7 7 o7 P7 1w)Nr} r r0 completed)r] ry r. )g1g2r r rA s r test_2z?AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_2 s1 B 59_a 0 59_a 0""#56
Bi
""#56
Bi
B 5Y#7 7 ; 5Y#7 7 ; 5Y#7 7 C 5Y#7 7 C - ,
8 7 7 7s E D3 E D6 E D:,D8-D:1 E EEE &E E E &E' E E E (E) E 6E 8D::E?E EE
E E E E r c } | d }j t 5 t j |j 5 }|j d d d d d d d y # 1 sw Y xY w# 1 sw Y y xY wNr )ry r
contextlibclosing __await__r )pobjrX r r rA s r test_sendzBAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_send st A;'C""=1
! ''
8 !AFF4L!
!
!! !
!
!s# $A: A. A:.A7 3A::Bc x K } | d }j t |j t ywr )ry r> r )r r r r rA s r
test_throwzCAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_throw s3 A;'C k399k B s 7:)r r r] ry r. )
rA r r r r& r r r r rX s
``` @r r z/AsyncGenAsyncioTest._check_async_iterator_anext s K ii**795 67
1
2 4 II ( ( 3 4 " --fh7 - ! --jl; -O 4 4s !DDc , d }| j | y )Nc K d d y wNr} r r r r r agenz<AsyncGenAsyncioTest.test_async_generator_anext.<locals>.agen GGr r )rA r s r test_async_generator_anextz.AsyncGenAsyncioTest.test_async_generator_anext s
''-r c : G d d }| j | y )Nc " e Zd ZdZd Zd Zd Zy)IAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter Asynchronously yield 1, then 2.c d| _ y Nr yieldedr s r __init__zRAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__init__ r c | S r# r r s r rq zSAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__aiter__ r c ~ K | j dk\ r
t | xj dz
c_ | j S wNr r} r r. r s r r/ zSAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__anext__ s3 <<1$,..LLA%L <<'s ;=N)r r r
__doc__r rq r/ r r r MyAsyncIterr s 1
!
(r r r )rA r s r test_python_async_iterator_anextz4AsyncGenAsyncioTest.test_python_async_iterator_anext s ( (
'' 4r c H dd l G fdd }| j | y )Nr c D e Zd ZdZd Zd ZW j d Zy)fAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoror c d| _ y r r r s r r zoAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__init__ r r c | S r# r r s r rq zpAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__aiter__ r r c 3 K | j dk\ r
t | xj dz
c_ | j S wr
r r s r r/ zpAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__anext__ s6 <<1$,..LLA%L <<'s <>N)r r r
r r rq coroutiner/ )r s r MyAsyncIterWithTypesCoror s& 1
!
__
(
(r r )r r )rA r r s @r 0test_python_async_iterator_types_coroutine_anextzDAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext s! ( (
''(@Ar c d } | fd}| j j | }| j |ddg y )Nc K d d y wr r r r r r( z5AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.gen r r c X K t 2 cg c3 d { } | 7 6 c} S c c} w wr# aiter)r' rX s r r z9AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.consume s& %*1X..A.. ..s$ *%!
!%!%*r} r r r r] )rA r( r r& rX s @r test_async_gen_aiterz(AsyncGenAsyncioTest.test_async_gen_aiter s@
E /ii**795 q!f%r c g G d d } | fd}| j j | | j ddg y )Nc e Zd Zd Zy);AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Genc K d d y wr r r s r rq zEAsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Gen.__aiter__ s r Nr r r
rq r r r Genr$ s
r r' c K t } j t | d { $7 # t $ r Y y w xY wwr# )r r% r r. )aitrX r s r r z?AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.consume# sD (CNNs#34 #3) s0
A6 46 A6 AAAAr} r r )rA r' r rX r s @@r test_async_gen_aiter_classz.AsyncGenAsyncioTest.test_async_gen_aiter_class sJ
E
$$WY/ 1a&)r c d d }t | }t | }| j || y )Nc K d y wNr} r r r r r( z6AsyncGenAsyncioTest.test_aiter_idempotent.<locals>.gen. Gr )r rh )rA r( applied_once
applied_twices r test_aiter_idempotentz)AsyncGenAsyncioTest.test_aiter_idempotent- s* SU| l+
lM2r c d d }fd}fd}fd}| j t 5 | j j | d d d | j t 5 | j j | d d d | j t 5 | j j | d d d | j t 5 | j j | d d d y # 1 sw Y xY w# 1 sw Y xY w# 1 sw Y `xY w# 1 sw Y y xY w)Nc K d y wr- r r r r r( z4AsyncGenAsyncioTest.test_anext_bad_args.<locals>.gen5 r. r c 4 K t d { y 7 wr# r r r r call_with_too_few_argszGAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_few_args7 'MM c F K t dd d { y 7 wNr} r r r( s r call_with_too_many_argszHAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_many_args9 s q!$ $ $s ! !c D K t d d { y 7 wr- r r: s r call_with_wrong_type_argszJAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_wrong_type_args; s 35/ ! ! c D K t d { y 7 w)N) aiteratorr r: s r call_with_kwargz@AsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_kwarg= s #%( ( (r> ry r5 r r )rA r5 r; r= rA r( s @r test_anext_bad_argsz'AsyncGenAsyncioTest.test_anext_bad_args4 s % " )
y
) C II ( ()?)A B C
y
) D II ( ()@)B C D
y
) F II ( ()B)D E F
y
) < II ( ( ): ; < <
C C D D F F < <s/ !D*!D (!D(&!D4D D%(D14D=c t fd} j j | } j |d y )Nc ^ K G d d G fdd } d}t | d }j t | 5 | d { d d d t | }j t | 5 | d { d d d y7 F# 1 sw Y ExY w7 # 1 sw Y yxY ww)Nc e Zd Zd Zy)UAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitablec y)N* r r s r r z_AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitable.__await__K s r Nr r r
r r r r BadAwaitablerG J s r rK c e Zd Zd Z fdZy)TAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIterc | S r# r r s r rq z^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__aiter__N s Kr c S r# r )rA rK s r r/ z^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__anext__P s '>)r Nr r r
rq r/ )rK s r r rM M s
*r r z__await__.*iteratorr0 r )r r= r5 )r regexr rK rA s @r
bad_awaitablez?AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitableI s
*
*
+E kmY7I'' 59
km,I'' 59
sZ A B-B
B B.B-=B!B B! B-BB B- B!!B*&B-r r )rA rR r s ` r test_anext_bad_awaitz(AsyncGenAsyncioTest.test_anext_bad_awaitH s0 " --mo> -r c & K t | d }| j t 5 | d { d d d t | }| j t 5 | d { d d d y7 E# 1 sw Y DxY w7 # 1 sw Y yxY wwNr0 r )r ry r5 )rA aiter_classr s r check_anext_returning_iteratorz2AsyncGenAsyncioTest.check_anext_returning_iterator] s +-3
y
) OO +-(
y
) OO
sU 'BA7A5A7-B!B'B(B, B5A77B <BBB
Bc G d d }| j j | j | }| j |d y )Nc e Zd Zd Zd Zy)EAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnextc | S r# r r s r rq zOAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__aiter__h r r c t d S )Nabc)iterr s r r/ zOAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__anext__j s E{"r NrP r r r
WithIterAnextrZ g s
#r r_ r r r rW r] )rA r_ r s r test_anext_return_iteratorz.AsyncGenAsyncioTest.test_anext_return_iteratorf s> # #
--d.Q.QR_.`a -r c G d d }| j j | j | }| j |d y )Nc e Zd Zd Zd Zy)EAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnextc | S r# r r s r rq zOAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__aiter__q r r c 3 K d y wr# r r s r r/ zOAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__anext__s s s NrP r r r WithGenAnextrd p s
r rg r r` )rA rg r s r test_anext_return_generatorz/AsyncGenAsyncioTest.test_anext_return_generatoro s>
--d.Q.QR^._` -r c G d d G fdd fd} j j | } j |d y )Nc e Zd Zd Zy)EAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitablec 3 K t wr# r~ r s r r zOAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitable.__await__z s '))s
NrJ r r r RaisingAwaitablerk y s
r rn c e Zd Zd Z fdZy)NAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnextc | S r# r r s r rq zXAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__aiter__~ r r c S r# r )rA rn s r r/ zXAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__anext__ s '))r NrP )rn s r WithRaisingAwaitableAnextrp } s
*r rs c ( K t } j t 5 | d { d d d t d } j t 5 | d { d d d y7 F# 1 sw Y ExY w7 # 1 sw Y yxY wwrU )r ry r~ )r rs rA s r do_testz<AsyncGenAsyncioTest.test_anext_await_raises.<locals>.do_test s 7 9:I""#45
7 99EI""#45
sU &BA8A6A8.B"B(B)B- B6A88B=BBB Br r )rA ru r rn rs s ` @@r test_anext_await_raisesz+AsyncGenAsyncioTest.test_anext_await_raisesx sD * *
--gi8 -r c
t j d G d dt fd
fd}
fd}
fd} fd} fd } fd
} fd } || || || || || || y ) Nc 3 K | S wr# r vs r _async_yieldz9AsyncGenAsyncioTest.test_anext_iter.<locals>._async_yield s G s c e Zd Zy)4AsyncGenAsyncioTest.test_anext_iter.<locals>.MyErrorNr
r r r MyErrorr} r r~ c l K d d { y 7 # $ r d d { 7 Y y w xY wwr r r~ r{ s r agenfnz3AsyncGenAsyncioTest.test_anext_iter.<locals>.agenfn sA
&"1o%%
&
&"1o%%
&0 4 4 1+1414c }t j | |d j 5 }j |j d d j |j d |j d j
d j j d d d d y # t $ r }|}Y d }~5d }~ww xY w# 1 sw Y y xY w)Nr0 r} r rp ) r r r r] r r rr r value)r r rX eerrr~ r rA s r test1z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test1 s 8D##E$ $:$D$D$FG
71 q1 !3Q7>FF4L II <= I6
7
7
% C
7
7s6 AC<C
-C C CCCCC$c }t j | |d j 5 }j |j d d j |j d j
5 |j d d d d d d y # 1 sw Y xY w# 1 sw Y y xY w)Nr0 r} r )r r r r] r r ry )r r rX r~ r rA s r test2z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test2 s 8D##E$ $:$D$D$FG
'1 q1 !3Q7&&w/ 'GGGI&'
'
'' '
'
's$ AC B4#C 4B= 9C C c }t j | |d j 5 }j |j d d |j j
t d 5 j |j d d d d d d d d y # 1 sw Y xY w# 1 sw Y y xY w)Nr0 r} z cannot reuse)r r r r] r r r= r )r r rX r rA s r test3z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test3 s 8D##E$ $:$D$D$FG
61 q1 ++L.I 6$$QVVD\156
6
66 6
6
6s$ AB:;"B. B:.B7 3B::Cc t j d fd} | }t j | |d j 5 }j |j
d d j |j d j d 5 |j d d d d d d d y # 1 sw Y xY w# 1 sw Y y xY w)Nc 3 , K | dz | dz dz S wNr r} r ry s r r{ zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>._async_yield "f 2vz*+ c l K d d { y 7 # $ r d d { 7 Y y w xY wwr r r s r r zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>.agenfn sA *&q/)) * *&q/))*r r0 r r val) r r r r r r] r r r= r r r rX r{ r~ rA s @r test4z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test4 s
__
,
,
8D##E$ $:$D$D$FG
,1 r2 !3R8++GU; ,GGGEN+,
,
,, ,
,
,s% AC *CC C C C(c t j d fd} | }t j | |d j 5 }j |j
d d j t d 5 |j d d d d d d y # 1 sw Y xY w# 1 sw Y y xY w)Nc 3 , K | dz | dz dz S wr r ry s r r{ zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>._async_yield r r c T K d d { d y 7
# $ r Y y w xY wwNr} aaar r s r r zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>.agenfn s6 &q/)) * s( ( ( %(%(r0 r )
r r r r r r] r r= r r r s @r test5z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test5 s
__
,
,
8D##E$ $:$D$D$FG
'1 r2++M9E 'GGGI&'
'
'' '
'
's$ 8B<B0 B<0B9 5B<<Cc B t j d fd} | }t j | |d j 5 }j 5 |j
d d d d d d y # 1 sw Y xY w# 1 sw Y y xY w)Nc 3 , K | dz | dz dz S wr r ry s r r{ zHAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>._async_yield r r c < K d d { d y 7
wr r )r{ s r r zBAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>.agenfn s "1o%% &s r0 )r r r r r ry r r s @r test6z2AsyncGenAsyncioTest.test_anext_iter.<locals>.test6 s
__
,
,
8D##E$ $:$D$D$FG
'1&&w/ 'GGGI&'
'
'' '
'
's$ B!B 8B B BB c j d 5 | t d d d j d 5 | t d d d y # 1 sw Y 0xY w# 1 sw Y y xY w)Nzpure-Python anext()zbuiltin anext())r r7 r )testrA s r run_testz5AsyncGenAsyncioTest.test_anext_iter.<locals>.run_test sZ 34
X
/0
U
s
A
AAA$)r r rV ) rA r r r r r r r r~ r{ r s ` @@@r test_anext_iterz#AsyncGenAsyncioTest.test_anext_iter sy
i 7 ' 6 ,* '&
' r c d d }fd}d }| j t 5 | j j | d d d | j t 5 | j j | d d d | j t 5 | j j | d d d y # 1 sw Y xY w# 1 sw Y TxY w# 1 sw Y y xY w)Nc K d y wr- r r r r r( z4AsyncGenAsyncioTest.test_aiter_bad_args.<locals>.gen r. r c 4 K t d { y 7 wr# r r r r r5 zGAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_few_args r6 r7 c D K t d d { y 7 wr- r r: s r r; zHAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_many_args s q/ ! !r> c 6 K t d d { y 7 wr- r r r r call_with_wrong_type_argzIAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_wrong_type_arg s (NNs rB )rA r5 r; r r( s @r test_aiter_bad_argsz'AsyncGenAsyncioTest.test_aiter_bad_args s "
y
) C II ( ()?)A B C
y
) D II ( ()@)B C D
y
) E II ( ()A)C D E E C C D D E Es# !C #!C!!C# CC #C,c R K g }|2 3 d { }|j | 7 6 |S wr# r$ )rA r( r& r' s r r* zAsyncGenAsyncioTest.to_list s2 ! JJqM s
s '$"$'$'c d }| j j | j | }| j |ddg y )Nc K d t j d d { d t j d d { y 7 '7 wNr} {Gz?r r sleepr r r r( z:AsyncGenAsyncioTest.test_async_gen_asyncio_01.<locals>.gen s@ G--% % %G--% % %
& %s! A A!A A
A
A r} r r r r* r] )rA r( r& s r test_async_gen_asyncio_01z-AsyncGenAsyncioTest.test_async_gen_asyncio_01 s< ii**4<<+>? q!f%r c d }| j t 5 | j j | j | d d d y # 1 sw Y y xY w)Nc r K d t j d d { d ddz d y 7 w)Nr} r r r r r r r r r( z:AsyncGenAsyncioTest.test_async_gen_asyncio_02.<locals>.gen! s3 G--% % %G
EG
&s 757)ry r~ r r r* rj s r test_async_gen_asyncio_02z-AsyncGenAsyncioTest.test_async_gen_asyncio_02 sJ
0
1 > II ( ( ce)< = > > >s 0AAc | j } G d d }|j | j | }| j |ddg y )Nc e Zd Zd Zy):AsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Genc ^ K d t j d d { d y 7
wr r r s r rq zDAsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Gen.__aiter__/ s' mmD))) *s -+ -Nr& r r r r' r . s
r r' r} r r )rA r r' r& s r test_async_gen_asyncio_03z-AsyncGenAsyncioTest.test_async_gen_asyncio_03+ sF yy %%dll35&9: q!f%r c d fd} fd} j j | j j | y )Nc K d t j d d { d d t j d d { d y 7 2# t $ r d Y 5w xY w7 w)Nr} r r r )r r r~ r r r fooz@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.foo8 sc G--% % %
--% % %G
& %
%s= A+AA+
A A+A) A+A&#A+%A&&A+c K j } j | j d { d j | j d { d j | j d { d j | j d { d j t 5 | j d { d d d j t 5 | j d { d d d y 7 7 7 7 |7 K# 1 sw Y JxY w7 ## 1 sw Y y xY ww)Nr} r r r )rq r] r/ ry r. )itr rA s r run1zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run1C s "B 2<<> 11 5 2<<> 11 5 2<<> 11 5 2<<> 11 5""#56
%lln$$
%""#56
%lln$$
%
%
2 1 1 1$
%
% %
%
%s 4E
D&'E
D( 'E
D*'E
/D,0 E
D0"D.#D0' E
D>D<D>
E
(E
*E
,E
.D00D95E
<D>>EE
c K j } j | j d { d j | j d { d | j j t j d j | j d { d j t 5 | j d { d d d y 7 7 # t $ r)}j |j d d Y d }~d }~ww xY w7 y7 H# 1 sw Y y xY ww)Nr} r rp r r r )
rq r] r/ r r~ rr r r ry r. r r r rA s r run2zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run2O s "B 2<<> 11 5 2<<> 11 5
: $$%67 89 2<<> 11 5""#56
%lln$$
%
% 2 1 !
3 T22
3 2$
%
%s 4EC='E C? E*#D
/E<D6= ED:/D80D:4
E?E D3
D.)E.D33E8D::E?Er r )rA r r r s ` @r test_async_gen_asyncio_anext_04z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_047 s<
%
%
$$TV, $$TV,r c Z d fd} j j | y )Nc 0 K d} | } | dz y wNr} r r ry s r r z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.foob s AAc'Ms c $ K j } | j j d j d | j j d j d | j j d j d j t 5 | j d { d d d y # t $ r)}j |j d d Y d }~d }~ww xY w# t $ r)}j |j d d Y d }~d }~ww xY w# t $ r)}j |j d d Y d }~d }~ww xY w7 # 1 sw Y y xY ww)Nrp r r} r i ) rq r/ r rr r r] r ry r. r s r runz@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.rung sO "B
: ##D) 89
: ##B' 89
: ##B' 89""#56
%lln$$
%
%' !
0 Q//
0 !
1 R00
1 !
3 T22
3 %
%
%s F C# F D *F< E
&FFFF F# D, D FDF E
! E FE
F
E? E:5F:E??FFF
Fr rA r r s ` @r test_async_gen_asyncio_anext_05z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05a s#
%6
$$SU+r c 6 dd } | }|j d j t 5 |j d d d d fd fd} j j | j d y # 1 sw Y HxY w)Nr c 3 $ K d y # Y y xY wwr# r r r r r z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.foo
c 0 K d d y # Y d y xY wwr- r DONEs r r( z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.gen $
D
D
c K } | j d d { j t 5 | j d d { d d d dz
y 7 A7 # 1 sw Y xY wwNr )r ry r. rX r r( rA s r r z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.run sf A''$- ""#56
$ggdm##
$ BJD
#
$
$s8 A1A!A1A%A#A%A1#A%%A.*A1 )r ry r r r r] rA r rX r r r( s ` @@r test_async_gen_asyncio_anext_06z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06 s
E t
}
-
FF4L
$$SU+ r"- s BBc Z d fd} j j | y )Nc @ K d y # t $ r d Y y w xY ww)Nr} r rm r r r r zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.foo s#
$
c K j } j | j d { d j t 5 }| j j t d d d j j j d d j t 5 | j d { d d d y 7 # 1 sw Y kxY w7 # 1 sw Y y xY ww)Nr r r )
rq r] r/ ry r r r~ exceptionr r. )r cmr rA s r r zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.run s "B 2<<> 14 8""=1
8R $$%67
8 R\\ . .q 14 8""#56
%lln$$
%
% 2
8
8 %
%
%sR 4C>C" C>$C$:AC> C2C0C2
C>$C-)C>0C22C;7C>r r s ` @r "test_async_gen_asyncio_anext_tuplez6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple s# %
$$SU+r c Z d fd} j j | y )Nc d K t d y # t $ r t d Y y w xY wwr9 )r r~ r r r r zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.foo s/
'#A&&$
'#A&&
's 0 0-0-0c K j } | j d { }j |t j |j
d j
t 5 }| j j t d d d j j d }j |t j |j
d j
t 5 | j d { d d d y 7 # 1 sw Y xY w7 # 1 sw Y y xY ww)Nr} r r ) rq r/ r r r] r ry r r~ r r r. )r rz r r rA s r r zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.run s "Blln$A ! !!] 3 QWWa (""=1
8R $$%67
8 !!!$A ! !!] 3 QWWa (""#56
%lln$$
%
% %
8
8 %
%
%sS )ED&A E8$D( A(ED6D4D6
E(D1-E4D66D?;Er r s ` @r *test_async_gen_asyncio_anext_stopiterationz>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration s# ' %
$$SU+r c d fd}| j t d 5 | j j | d d d y # 1 sw Y y xY w)Nc K d ddz t j d d { d y 7
# t j d d { 7 d w xY ww)Nr} r r r r r r r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.foo sJ
A mmD))) *gmmD)))s. A
3 A1 AA A
AAc K } | j }|j d { | j d { y 7 7 wr# rq r/ r r( r r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.run @ %C B,,. **,
! ! +AA AAAAz%async generator ignored GeneratorExit)r= r r r r s @r test_async_gen_asyncio_aclose_06z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06 sN
#
# 79 0
II ( ( / 0 0 0s !A
Ac dfdfd}| j j | | j d y )Nr c @ K d ddz t j d d { t j d d { dz
dz
y 7 ,7 # t j d d { 7 t j d d { 7 dz
w xY ww)Nr} r r r r r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.foo s
A mmD))) mmD))) DLD *) mmD))) mmD))) sO B
A B A B AB B B1A42 BB BB c K } | j }|j d { | j d { y 7 7 wr# r r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.run r r r} r )rA r r r s @@r test_async_gen_asyncio_aclose_07z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07 s8
$$SU+ q!r c H dt j j fd fd} j j | j d j j j t j
d y )Nr r c b K d d { dz
d t j d d { t j d d { dz
dz
y 7 S7 .7 # t j d d { 7 t j d d { 7 dz
w xY ww)Nr} r r r r )r r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.foo s
mmD))) mmD))) DLD *) mmD))) mmD))) se B/
A) A#A) B/A% B/A'B/#A) %B/'B/)B,B B, B#! B,,B/c K } | j }j |j d { d | j d { y 7 "7 wr- )rq r] r/ r )r( r r rA s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.run sJ %C B 2<<> 11 5**, 2 s! 6A A A A A A r} r )r Futurer r r] cancelr )rA r r r r s ` @@@r test_async_gen_asyncio_aclose_08z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08 sr nn$))n,
$$SU+ q!
$$W]]4%89r c dfdfd}| j j | | j d y )Nr c f K d # t j d d { 7 d w xY wwNr} r r r s r r( zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.gen s3
G mmA&&&s 1 .(.1c K } | j d { | j d { ~ t t j d d { t j d d { y 7 b7 L7 &7 wr )r/ r r r )rX r( s r r zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.run' sm A++- ++- L --" " "--" " "
# "sC B BB B'B B B ;B<B B B B r} r )rA r r r( s @@r #test_async_gen_asyncio_gc_aclose_09z7AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09 s8
#
$$SU+ q!r c dd } | }|j d |j fdfd}| j j | | j d y )Nr c 3 $ K d y # Y y xY wwr# r r r r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.foo: r r c 0 K d d y # Y d y xY wwr- r r s r r( zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.genE r r c K } | j d d { | j d { dz
y 7 "7 wr )r r )rX r r( s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.runM s@ A''$- ((* BJD
s AAAA AAr )r r r r r] r s @@r test_async_gen_asyncio_aclose_10z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_106 sZ
E t
$$SU+ r"r c 6 dd } | }|j d j t d 5 |j d d d fd fd} j j | j
d y # 1 sw Y HxY w)Nr c 3 , K d d y # Y xY wwr# r r r r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.foo[ s
s
ignored GeneratorExitc < K d d dz
y # Y xY wwr- r r s r r( zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.genh s&
AID
s c K } | j d d { j t d 5 | j d { d d d dz
y 7 A7 # 1 sw Y xY ww)Nr r )r r= r r r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.runq sf A''$- '' 6MN
!hhj
! BJD
!
!s8 A1A!A1A%A#A%A1#A%%A.*A1r )r r= r r r r r] r s ` @@r test_async_gen_asyncio_aclose_11z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11W s
E t
#
#L2I
J
GGI
$$SU+ r"/ s BBc dd fdfd}| j j | | j d y )Nr c T K t j d d { ddz y 7
w)Nr r} r r r r r targetzDAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.target s$ --% % %
E
& (& (c K t j } d | d { y 7 # t $ r dY y w xY w# | d { 7 w # t $ r dY w w xY wxY wwr- )r create_taskr~ )taskr r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.foo sb &&vx0D
JJ( D JJ( D sp A%A 2 02 A%2 A A%A A%A"A
A
AA" A A" A A""A%c K } | j }|j d { | j d { y 7 7 wr# r r s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.run r r r} r )rA r r r r s @@@r test_async_gen_asyncio_aclose_12z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12| s=
$$SU+ q!r c ( dd } | }|j d } j |d |j d } j |d fd fd} j j | j d y )Nr c 3 " K d} | dz y wr r ry s r sgenzAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.sgen s Aa%Kr r} r c K t j d d { d} t j d d { | dz t j d d { t j d d { t j d d { dy 7 7 i7 F7 *7 # t j d d { 7 t j d d { 7 dw xY wwNr r} r r )rz r s r r( z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.gen s
mmD)))G mmD)))!e mmD))) mmD))) mmD))) *)) *) mmD))) mmD)))s C4B1 B'!B1 B) $B1 $B+%B1 *C4B- C4 B/ C4'B1 )B1 +B1 -C4/C41C1
C
C1(C+)C11C4c Z K } | j d d { }j |d | j d d { }j |d j t 5 | j d d { d d d y 7 y7 P7 # 1 sw Y y xY ww)Nr} r r )r r] ry r. rX rz r( rA s r r z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.run s Aggdm#A Q "ggcl"A Q $""#56
$ggdm##
$
$
$ # $
$
$K B+B*B+
B +B+6B B B
B+B+ B B($B+)r r] r r )rA r r rz r r r( s ` @@r test_async_gen_asyncio_asend_01z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01 s V GGDM A GGCL C
$
$$SU+ q!r c dd fd fd} j t 5 j j | d d d j d y # 1 sw Y xY w)Nr c T K t j | d { ddz y 7
wr r )delays r
sleep_n_crashzJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.sleep_n_crash s$ --& & &
E
'r c K t j d d { d} d d { dz
| dz t j d d { t j d d { dy 7 c7 P7 (7
# t j d d { 7 t j d d { 7 dw xY wwNr r} r r r rz r r& s r r( z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.gen
mmD)))G#D))) !e mmD))) mmD))) *) *) mmD))) mmD)))x C B BB BB C B C 9B:C B B C C C "B%# C CC C c K } | j d d { }j |d | j d d { y 7 07 wr r r] r s r r z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.run J Aggdm#A Q "''#, $
! AA*A
A AAr} )ry r~ r r r] rA r r r( r& s ` @@@r test_async_gen_asyncio_asend_02z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02 sa
0
1 0 II ( ( / 0 q! 0 0s !A''A0c d fdfd fd} j t j 5 j j | d d d j d y # 1 sw Y xY w)Nr c K t j t j | j j j | dz fd d { S 7 w)Nr r c $ j S r# r r s r <lambda>z\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash.<locals>.<lambda>
CJJL r r
ensure_futurer r
call_laterr% r rA s @r r& zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash Q ''
e(<-1YY ( 8C II ,@ A 9 9 A A' A%!A'c K t j d d { d} d d { dz
| dz t j d d { t j d d { dy 7 c7 P7 (7
# t j d d { 7 t j d d { 7 dw xY wwr( r r) s r r( z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.gen r* r+ c K } | j d d { }j |d | j d d { y 7 07 wr r- r s r r z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.run r. r/ r} )ry r CancelledErrorr r r] r0 s ` @@@r test_async_gen_asyncio_asend_03z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03 sf
w 5 5
6 0 II ( ( / 0 q! 0 0s !A33A<c d G d dt fd} | }|j d } j |d |j } j |d j t
5 |j d d d d fd fd} j j | j d y # 1 sw Y IxY w) Nr c e Zd Zy)CAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.FooErNr
r r r FooErrE r r rF c 3 @ K d} | dz y # $ r d} Y w xY ww)Nr} r r r )rz rF s r r zBAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.sgen
s3
G a%K
s r} c K t j d d { d} | dz t j d d { t j d d { t j d d { dy 7 l# $ r# d} t j d d { 7 Y w xY w7 n7 S7 8# t j d d { 7 t j d d { 7 dw xY wwr( r )rz r rF s r r( zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.gen s
mmD))). A !e mmD))) mmD))) mmD))) * . A!-----. * *) mmD))) mmD)))s D B= B
B= B B= B7 B=
D %B9& D B;D
B= B4+B.,B41B= 3B44B= 9D ;D =C=C C=4C75C==D c Z K } | j d d { }j |d | j d { }j |d j t 5 | j d d { d d d y 7 y7 P7 # 1 sw Y y xY ww)Nr} rH )r r] r ry r. )rX rz rF r( rA s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.run) s Aggdm#A Q "hhuo%A Q %""#56
$ggdm##
$
$
$ & $
$
$r! )rV r r] r ry r r r )rA r r rz r r rF r( s ` @@@r test_async_gen_asyncio_athrow_01z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01 s I V GGDM A HHUO D!
}
- GGDM "
$
$$SU+ q!C s =CC c $ d G d dt fdfd fd} j t j 5 j j | d d d j
d y # 1 sw Y xY w)Nr c e Zd Zy)CAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.FooErNr
r r r rF rN ; r r rF c K t j t j | j j j | dz fd d { S 7 w)Nr r c $ j S r# r5 r6 s r r7 z]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash.<locals>.<lambda>A r8 r r9 r< s @r r& zKAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash> r= r> c K t j d d { d} dz t j d d { t j d d { t j d d { dy 7 l# $ r d d { 7 Y |w xY w7 _7 D7 )# t j d d { 7 t j d d { 7 dw xY wwr r )rz r rF r& s r r( zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.genD s
mmD))). A !e mmD))) mmD))) mmD))) * .'---. * *) mmD))) mmD)))s C1B. B
B. B B. B( B.
C1%B*& C1B,C1
B. B% B B%"B. $B%%B. *C1,C1.C.C
C.%C(&C..C1c $ K } | j d d { }j |d | j d { j d y 7 B7 # t j
$ r j d w xY ww)Nr} z CancelledError was not raised)r r] r rr r rA )rX rz r rF r( rA s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.runT s Aggdm#A Q "
;hhuo%%
9: $ &))
q)
s8 BA"BA& A$ A& B$A& &'B
Br} )rV ry r rA r r r] )rA r r rF r( r& s ` @@@@r test_async_gen_asyncio_athrow_02z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_028 sr I ;
w 5 5
6 0 II ( ( / 0 q! 0 0s
!BBc > dd } | }|j d j t 5 |j t d d d fd fd} j
j
| j d y # 1 sw Y HxY w)Nr c 3 $ K d y # Y y xY wwr# r r r r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.fooj r r c 0 K d d y # Y d y xY wwr- r r s r r( zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.genv r r c K } | j d d { j t 5 | j t d { d d d dz
y 7 E7 # 1 sw Y xY wwr )r ry r. r
ValueErrorr s r r zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.run~ sg A''$- ""#56
+hhz***
+ BJD
*
+
+s8 A5A%A5A)A'A)A5'A))A2.A5r )r ry r r rX r r r] r s ` @@r test_async_gen_asyncio_athrow_03z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03f s
E t
}
-
GGJ
$$SU+ r"- s BB c Z d fd} j j | y )Nc @ K d y # t $ r d Y y w xY wwNr} r rm r r r r( zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.gen s#
$
r c b K } | j d d { }j |d | j t d { }j |d j t
5 | j d d { d d d y 7 }7 P7 # 1 sw Y y xY wwr\ )r r] r r~ ry r. r s r r zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.run s Aggdm#A Q "hh 011A Q %""#56
$ggdm##
$
$ $1 $
$
$sK B/B .B/B +B/:B#B!B#
B/ B/!B##B,(B/r rA r r( s ` @r #test_async_gen_asyncio_athrow_tuplez7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple s# $
$$SU+r c Z d fd} j j | y )Nc R K d y # t $ r t d Y y w xY wwr )r~ r r r r r( zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.gen s)
'$
'#A&&
's '
'$'$'c K } | j d d { }j |d | j t d { }j |t
j |j d j t 5 | j d d { d d d y 7 7 p7 # 1 sw Y y xY wwr ) r r] r r~ r r r ry r. r s r r zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.run s Aggdm#A Q "hh 011A ! !!] 3 QWWa (""#56
$ggdm##
$
$ $1 $
$
$sL CB=.CB?A CC/C0C4
C?CCC Cr r^ s ` @r +test_async_gen_asyncio_athrow_stopiterationz?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration s# ' $
$$SU+r c dfdfd}| j j | }| j j | }| j j t j d |j |j | j
t j 5 | j j | d d d | j
t j 5 | j j | d d d | j j | j j | j d y # 1 sw Y xY w# 1 sw Y [xY w)Nr c K t j | d { d t j d d { dz
y 7 ,7 # t j d d { 7 dz
w xY wwr r )timeout finalizeds r waiterzFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waiter sd
mmG,,, mmA&&&Q - 'gmmA&&&Q sH A6A A
A A6A
A6
A A6A3'A*( A33A6c 8 K d 2 3 d { }
7 6 y wr- r )_rh s r waitzDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.wait s% !!9
a
9s g?r )
r r r r r r ry rA shutdown_asyncgensr] )rA rk t1t2rg rh s @@r "test_async_gen_asyncio_shutdown_01z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01 s YY
"
"46
*
YY
"
"46
* $$W]]3%78
w 5 5
6 - II ( ( , -
w 5 5
6 - II ( ( , -
$$TYY%A%A%CD A& - - - -s < E)? E5)E25E>c g fdd } | fd}t j | | j g y )Nc ( j | y r# r$ r contextmessagess r exception_handlerzQAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.exception_handler OOG $r c K d d y wr r r r r r\ zMAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.async_iterate r r c x K t j } | j 2 3 d { } y 7 6 y wr# r get_running_loopset_exception_handlerr r' ru r s r mainzDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.main > ++-D & &'8 9
a
2 (:868:8:r r r] )rA r\ r} ru r rt s @@@r "test_async_gen_asyncio_shutdown_02z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02 s@ % _ DF 2&r c g fdd } | fd}t j | \ }| j |d | j |d t | j d|d y )Nc ( j | y r# r$ rr s r ru z[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.exception_handler rv r c @ K d d ddz y # ddz w xY wwNr} r r r r r r r\ zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.async_iterate #
!!
c x K t j } | j 2 3 d { } y 7 6 y wr# ry r| s r r} zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.main r~ r asyncgenr z:an error occurred during closing of asynchronous generatormessage)r r r] r r~ r )rA r\ r} r ru r rt s @@@r ,test_async_gen_asyncio_shutdown_exception_01z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01 sy % _ DF ,b1 gk 24EF
R i( *r c g fdd fd}t j | \ }| j |d t | j d|d y )Nc ( j | y r# r$ rr s r ru z[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.exception_handler rv r c @ K d d ddz y # ddz w xY wwr r r r r r\ zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.async_iterate r r c K t j } | j 2 3 d { } t y 7 6 t y wr# )r rz r{ r r r' r\ ru s r r} zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.main sJ ++-D & &'8 9(?
a L
? Ls% -AAAA
AA Ar z1unhandled exception during asyncio.run() shutdownr )r r r r~ r )rA r} r r\ ru rt s @@@r ,test_async_gen_asyncio_shutdown_exception_02z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02 s[ % DF gk 24EF
I i( *r c d fdfd}| j j | }| j |t d D cg c] }|dz c} y c c}w )Nc t K t | D ]$ }t j d d { | & y 7 wNr )ranger r )nr' s r arangez@AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.arange s3 1X
mmD)))
)s '86
8c " d | 2 S )Nc 8 K | 3 d { }|dz 7
6 y wNr r ).0r' s r <genexpr>zXAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange.<locals>.<genexpr>' s 33AAE33s
r )r r s r make_arangezEAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange% s 33 3r c R K d 2 cg c3 d { } | 7 6 c} S c c} w wr r r' r s r r z=AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.run) & %0_55A55 55$ '"
" "'r r r r r] r )rA r r& r' r r s @@r test_async_gen_expression_01z0AsyncGenAsyncioTest.test_async_gen_expression_01 sP
4 6 ii**351 eBi 8q1u 89 8s A
c d fdfd}| j j | }| j |t dd D cg c] }|dz c} y c c}w )Nc L K t j d d { | S 7 wr r )r s r wrapz>AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.wrap0 s" --% % %H
&s $"$c , fdt | D S )Nc P K | ] } | d { s|dz y 7 wr r )r r' r s r r zXAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange.<locals>.<genexpr>6 s! =aT!W}}AE=}s &$& &)r )r r s r r zEAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange4 s =58= =r c R K d 2 cg c3 d { } | 7 6 c} S c c} w wr r r s r r z=AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.run8 r r r} r r r )rA r r& r' r r s @@r test_async_gen_expression_02z0AsyncGenAsyncioTest.test_async_gen_expression_02/ sR > 6 ii**351 eArl ;q1u ;< ;s
A
c g fdd fd}t j | | j g y )Nc ( j | y r# r$ rr s r ru z]AsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.exception_handlerB rv r c K d d y wr r r r r r\ zYAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.async_iterateE r r c K t j } | j 2 3 d { } y 7 6 y wr# ry r s r r} zPAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.mainI s@ ++-D & &'8 9(?
a
?s -?=;=?=?r )rA r} r\ ru rt s @@@r .test_asyncgen_nonstarted_hooks_are_cancellablezBAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable> s7 % DF X&r c Z d fd} j j | y )Nc K d d y wr r r r r r\ zUAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.async_iterateU r r c K } | j }| d { j t d 5 | d { d d d | j d { y 7 F7 '# 1 sw Y &xY w7 w)Nz4cannot reuse already awaited __anext__\(\)/asend\(\))r/ r= r r r nxtr\ rA s r r zKAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.runY st B,,.CII'' K
))+
sD A9A'A9A+A)A+A9!A7"A9)A++A40A9r rA r r\ s ` @r *test_async_gen_await_same_anext_coro_twicez>AsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twiceT s#
$$SU+r c Z d fd} j j | y )Nc K d d y wr r r r r r\ zVAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.async_iterateh r r c K } | j }| d { j t d 5 | d { d d d y 7 .7 # 1 sw Y y xY ww)Nz2cannot reuse already awaited aclose\(\)/athrow\(\))r r= r r s r r zLAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.runl sb B))+CII'' I
s8 A AA AAA
A AA A r r s ` @r +test_async_gen_await_same_aclose_coro_twicez?AsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twiceg s#
$$SU+r c V d fd}| j j | y )Nc K d d y wr r r r r r\ z[AsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.async_iteratez r r c K } | j d { | j d { y 7 7 wr# r )r r\ s r r zQAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.run~ s5 B))+ ))+
s A <A >A A r r s @r 0test_async_gen_aclose_twice_with_different_coroszDAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_corosx s#
$$SU+r c V d fd}| j j | y )Nc K d d y wr r r r r r\ zQAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.async_iterate r r c l K } | 2 3 d { }
7 6 | j d { 7 y wr# r )r rj r\ s r r zGAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.run s7 B
a
2))+ s$
44404r r s @r &test_async_gen_aclose_after_exhaustionz:AsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion s#
$$SU+r c V d fd}| j j | y )Nc & K t y wr# )objectr r r async_generatorz\AsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.async_generator s
(Ns c K } t j | j t j }|D ] }|j y wr# )r r r all_tasks get_stack)agtasksr r s r r zPAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.run sJ "B ,%%'E
!
!s AAr )rA r r s @r /test_async_gen_aclose_compatible_with_get_stackzCAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack s# !
$$SU+r N)9r r r
r r r r r r r r! r* r1 rC rS rW ra rh rv r r r* r r r r r r r r r r r r r r r r" r1 rB rK rS rY r_ rc ro r r r r r r r r r r r r r r r r s! %,
? 1.f.
5 B&&*"3<(.*...*obE
& >
&(-T!,F!#F,&,.0(". :>"6 #B##J"6("T "@ "D3"j,"\!#F,$,& 'D',*:*8:
= ',,&," , , ,r r __main__)r r unittestr test.support.import_helperr test.supportr r r r r6 rV r r r r r* r7 TestCaser9 rQ r r r} r r r <module>r s 4 <
" t $h Y
) + >. ** . b]98$$ ]9@ y,(++ y,x' zHMMO r 
Browse
Usage
Versions