+
    Bi                        ^ RI t ^ RIt^ RIt^ RIt^ RIHt ^ RIHtHt ]! R4      t	]! RR7       ]
! 4       t ! R R]4      t]P                  R	R
/R l4       tR tR t]3R lt ! R R]P&                  4      t ! R R]P&                  4      t ! R R]P&                  4      t ! R R]P&                  4      t]R8X  d   ]P2                  ! 4        R# R# )    N)import_module)
gc_collectrequires_working_socketasyncioT)modulec                       ] tR t^tRtR# )AwaitException N__name__
__module____qualname____firstlineno____static_attributes__r
       )/usr/lib/python3.14/test/test_asyncgen.pyr	   r	      s    r   r	   throwFc              #   2   "   V '       d   Rx  R# Rx  R# 5i)r   Nr   resultr
   r   s   $r   	awaitabler      s     s   c                     R p  V'       d   R pV P                  \        4      pMV P                  R4      p VR8X  g   K=  RpKA    \         d   pTP                  ^ ,          u Rp?# Rp?ii ; i)FTNr   )r   r	   sendStopIterationargs)coroexcfutexs   &   r   run_until_completer!      sa    
C
	jj0iio *C	  	771:	s'   A A A A,A'!A,'A,c                 0   a  V 3R  lp\        V! 4       4      # )c                  X   <"   . p S  R j  xL
  pV P                  V4       K   LDT # 5iNappend)resigens     r   iterateto_list.<locals>.iterate-   s1      	 	!JJqM	s
s   *'%'*'*)r!   )r)   r*   s   f r   to_listr,   ,   s     gi((r   c                   a aa  \        S 4      P                  oS\        J d	   S! S 4      # TTT 3R lpT! 4       #   \         d    \        S : R24      hi ; i)a  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                  X   <"    S ! S4      G R j  xL
 #  L  \          d    Su # i ; i5ir$   StopAsyncIteration)	__anext__defaultiterators   r   
anext_implpy_anext.<locals>.anext_implG   s1     	 #8,,,,! 	N	s(   *  * '*'*)typer1   AttributeError	TypeError_no_default)r3   r2   r4   r1   s   ff @r   py_anextr:   6   sb    BN,,	 +""	 <#  B8,&?@AABs	   ; Ac                   >   a  ] tR t^Ut o R tR tR tR tR tRt	V t
R# )AsyncGenSyntaxTestc                    R pV P                  \        R4      ;_uu_ 4        \        V/ / 4       RRR4       R#   + '       g   i     R# ; i)zJasync def foo():
            await abc
            yield from 123
        yield from.*inside asyncNassertRaisesRegexSyntaxErrorexecselfcodes   & r   test_async_gen_syntax_01+AsyncGenSyntaxTest.test_async_gen_syntax_01W   ;    
 ##K1KLLr2 MLLL	   9A
	c                    R pV P                  \        R4      ;_uu_ 4        \        V/ / 4       RRR4       R#   + '       g   i     R# ; i)z4async def foo():
            yield from 123
        r>   Nr?   rC   s   & r   test_async_gen_syntax_02+AsyncGenSyntaxTest.test_async_gen_syntax_02`   s;     ##K1KLLr2 MLLLrI   c                    R pV P                  \        R4      ;_uu_ 4        \        V/ / 4       RRR4       R#   + '       g   i     R# ; i)zXasync def foo():
            await abc
            yield
            return 123
        return.*value.*async genNr?   rC   s   & r   test_async_gen_syntax_03+AsyncGenSyntaxTest.test_async_gen_syntax_03h   ;     ##K1KLLr2 MLLLrI   c                    R pV P                  \        R4      ;_uu_ 4        \        V/ / 4       RRR4       R#   + '       g   i     R# ; i)zBasync def foo():
            yield
            return 123
        rN   Nr?   rC   s   & r   test_async_gen_syntax_04+AsyncGenSyntaxTest.test_async_gen_syntax_04r   rH   rI   c                    R pV P                  \        R4      ;_uu_ 4        \        V/ / 4       RRR4       R#   + '       g   i     R# ; i)zWasync def foo():
            if 0:
                yield
            return 12
        rN   Nr?   rC   s   & r   test_async_gen_syntax_05+AsyncGenSyntaxTest.test_async_gen_syntax_05{   rQ   rI   r
   N)r   r   r   r   rF   rK   rO   rS   rV   r   __classdictcell____classdict__s   @r   r<   r<   U   s#      r   r<   c                      a  ] tR t^t o R tR tR tR tR tR t	R t
R tR	 tR
 tR tR tR tR tR tR tR tR tR tR tR tRtV tR# )AsyncGenTestc                T    R  pR pV! V4      pV! V4      pV P                  WV4       V# )c                     . p  VP                  V P                  4       4       K#    \         d    TP                  R4        T# \         d/   pTP                  \	        \        T4      4      4        Rp?Ku  Rp?ii ; i)TSTOPN)r&   __next__r   	Exceptionstrr6   )gr'   r    s   &  r   sync_iterate5AsyncGenTest.compare_generators.<locals>.sync_iterate   sh    C.JJqzz|,$ JJv& J ! .JJs48}--.s!   & A=A=A=#A88A=c                    . p V P                  4       p   VP                  4        K    \         dW   pTP                  '       d)   TP	                  TP                  ^ ,          4        Rp?Kk  TP	                  R4        Rp?K  Rp?i\
         d    h \         d/   pTP	                  \        \        T4      4      4        Rp?K  Rp?ii ; i  \
         d    TP	                  R4        T# i ; i)TNzEMPTY StopIterationr_   )	r1   r`   r   r   r&   r0   ra   rb   r6   )rc   r'   anr    s   &   r   async_iterate6AsyncGenTest.compare_generators.<locals>.async_iterate   s    C[[]"KKM, &!www #

2771: 6 % #

+@ A %1 "!( "JJs48}5!" * JJv&Js`   C ) C C4B(C .B?C C
CC#CC CC C/.C/)assertEqual)rD   sync_gen	async_genrd   rh   sync_gen_resultasync_gen_results   &&&    r   compare_generatorsAsyncGenTest.compare_generators   s7    
		2 'x0(3;r   c                X   a  V 3R  lpS P                  \        V! 4       4      . RO4       R# )c                    <"   \        4       G R j  xL
  ^{5x p SP                  V R 4       \        4       G R j  xL
  R5x  \        4       G R j  xL
  R5x  R #  LK L$ L5i)N    )r   assertIs)arD   s    r   r)   5AsyncGenTest.test_async_gen_iteration_01.<locals>.gen   sS     +	AMM!T"+I+I  s1   A#A(A#AA#A!A#A#!A#N){   rs   rt   )rj   r,   rD   r)   s   f r   test_async_gen_iteration_01(AsyncGenTest.test_async_gen_iteration_01   s     	 	9r   c                `   R  pV! 4       pVP                  4       pVP                  4       pV P                  VP                  4       R4        VP                  4        V P	                  R4       VP                  4       pV P                  VP                  4       R4        VP                  4        V P	                  R4       R#   \
         d.   pT P                  TP                  ^ ,          ^{4        Rp?LRp?ii ; i  \         d'   pT P                  TP                  4        Rp?R# Rp?ii ; i)c                 h   "   \        4       G R j  xL
  ^{5x  \        4       G R j  xL
  R #  L L5ir$   r   r
   r   r   r)   5AsyncGenTest.test_async_gen_iteration_02.<locals>.gen   s(     +I+ s   2.2022StopIteration was not raisedNz!StopAsyncIteration was not raisedr   )		__aiter__r1   rj   r`   failr   r   r0   assertFalserD   r)   rc   airg   r    s   &     r   test_async_gen_iteration_02(AsyncGenTest.test_async_gen_iteration_02   s    	
 E[[]\\^4	6KKM II45\\^4	;KKM II9:  	.RWWQZ--	. " 	&RWW%%	&s0   C C< C9#C44C9<D-D((D-c                    R  pV P                  \        4      ;_uu_ 4        \        V! 4       4       RRR4       R#   + '       g   i     R# ; i)c                 v   "   \        4       G R j  xL
  ^{5x  \        RR7      G R j  xL
  R5x  R #  L$ L5i)NTr   rs   r~   r
   r   r   r)   5AsyncGenTest.test_async_gen_exception_03.<locals>.gen   s0     +I$'''I 's   959799N)assertRaisesr	   r,   ry   s   & r   test_async_gen_exception_03(AsyncGenTest.test_async_gen_exception_03   s2    	 ~..CEN /...s	   <A	c                   R  pV! 4       pVP                  4       pVP                  4       pV P                  VP                  4       R4        VP                  4        V P	                  R4       V P                  \        4      ;_uu_ 4        VP                  4       P                  4        RRR4       R#   \
         d.   pT P                  TP                  ^ ,          ^{4        Rp?LyRp?ii ; i  + '       g   i     R# ; i)c                 R   "   \        4       G R j  xL
  ^{5x  ^^ ,           R #  L5ir$   r~   r
   r   r   r)   5AsyncGenTest.test_async_gen_exception_04.<locals>.gen   s#     +IEE s   '%'r   Nr   )	r   r1   rj   r`   r   r   r   r   ZeroDivisionErrorr   s   &     r   test_async_gen_exception_04(AsyncGenTest.test_async_gen_exception_04   s    	
 E[[]\\^4	6KKM II45011LLN##% 21  	.RWWQZ--	.
 211s$   B3 
C.3C+>#C&&C+.C?	c                    R  pV P                  \        R4      ;_uu_ 4        \        V! 4       4       RRR4       R#   + '       g   i     R# ; i)c                     "   ^{5x  \         h5irx   r/   r
   r   r   r)   5AsyncGenTest.test_async_gen_exception_05.<locals>.gen   s     I$$   z#async generator.*StopAsyncIterationNr@   RuntimeErrorr,   ry   s   & r   test_async_gen_exception_05(AsyncGenTest.test_async_gen_exception_05   sE    	% ##L$IK KCENK K K K	   =A	c                    R  pV P                  \        R4      ;_uu_ 4        \        V! 4       4       RRR4       R#   + '       g   i     R# ; i)c                     "   ^{5x  \         h5ir   )r   r
   r   r   r)   5AsyncGenTest.test_async_gen_exception_06.<locals>.gen  s     Ir   zasync generator.*StopIterationNr   ry   s   & r   test_async_gen_exception_06(AsyncGenTest.test_async_gen_exception_06  sE    	  ##L$DF FCENF F F Fr   c                J    R  pR pV P                  V! 4       V! 4       4       R# )c               3   \   "    ^x  ^^ ,           ^x  ^x  ^dx  R#   ^x  ^x  i ; i5i   Nr
   r
   r   r   rk   :AsyncGenTest.test_async_gen_exception_07.<locals>.sync_gen  2     AI    , ,
),c                 h   "    ^5x  ^^ ,           ^5x  ^5x  ^d5x  R#   ^5x  ^5x  i ; i5ir   r
   r
   r   r   rl   ;AsyncGenTest.test_async_gen_exception_07.<locals>.async_gen  s2     AI s   2# 2/2Nro   rD   rk   rl   s   &  r   test_async_gen_exception_07(AsyncGenTest.test_async_gen_exception_07  s"    		 	
IK8r   c                J    R  pR pV P                  V! 4       V! 4       4       R# )c               3   n   "    ^x  ^x  ^^ ,           ^x  ^dx  R#   ^x  ^^ ,           ^x  i ; i5ir   r
   r
   r   r   rk   :AsyncGenTest.test_async_gen_exception_08.<locals>.sync_gen%  s9     AI	 As   5 525c                    "    ^5x  \        4       G Rj  xL
  \        4       G Rj  xL
  ^5x  ^^ ,           ^5x  ^d5x  R#  L0 L   \        4       G Rj  xL 
  ^5x  ^^ ,           ^5x  i ; i5ir   r~   r
   r   r   rl   ;AsyncGenTest.test_async_gen_exception_08.<locals>.async_gen/  s_     k!!k!!AI "!ik!!AsG   A6A AA A6A	A6A 	A6A3AA33A6Nr   r   s   &  r   test_async_gen_exception_08(AsyncGenTest.test_async_gen_exception_08$  "    	
	 	
IK8r   c                J    R  pR pV P                  V! 4       V! 4       4       R# )c               3   \   "    ^x  ^^ ,           ^x  ^x  ^dx  R#   ^x  ^x  i ; i5ir   r
   r
   r   r   rk   :AsyncGenTest.test_async_gen_exception_09.<locals>.sync_gen>  r   r   c                    "    \        4       G R j  xL
  ^5x  ^^ ,           ^5x  \        4       G R j  xL
  ^5x  ^d5x  R #  L5 L  ^5x  \        4       G R j  xL 
  ^5x  i ; i5ir$   r~   r
   r   r   rl   ;AsyncGenTest.test_async_gen_exception_09.<locals>.async_genH  s]     k!!Ak!!I "
 " k!!sG   A-A AA A-A	A-A 	A-A*A!A**A-Nr   r   s   &  r   test_async_gen_exception_09(AsyncGenTest.test_async_gen_exception_09=  r   r   c                    R  pV P                  \        R4      ;_uu_ 4        V! 4       P                  4       P                  ^d4       RRR4       R#   + '       g   i     R# ; i)c                    "   ^{5x  R# 5irx   Nr
   r
   r   r   r)   5AsyncGenTest.test_async_gen_exception_10.<locals>.genW  
     I   
z!non-None value .* async generatorN)r@   r8   r1   r   ry   s   & r   test_async_gen_exception_10(AsyncGenTest.test_async_gen_exception_10V  sQ    	##I$GI IEOO""3'I I I Is   %AA"	c                f   aa R  oV3R lpR oV3R lpV P                  V! 4       V! 4       4       R# )c               3      "   ^
x  ^x  R# 5i
   Nr
   r
   r   r   rk   :AsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen^  s     HH   c               3      <"   ^x  S! 4       p V P                  R4        V P                  \        4       4       ^x  R#   \         d    ^x   Li ; i5ir   )r   r   GeneratorExit)sgrk   s    r   sync_gen_wrapperBAsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen_wrapperb  sL     GBGGDM) G ! s'   AA  A AAAAc                 "   "   ^
5x  ^5x  R# 5ir   r
   r
   r   r   rl   ;AsyncGenTest.test_async_gen_exception_11.<locals>.async_genl  s     HH   c                    <"   ^5x  S! 4       p V P                  R4      G Rj  xL
   V P                  \        4       4      G Rj  xL
  ^5x  R#  L- L  \         d	    ^5x   Li ; i5ir   )asendathrowr   )asgrl   s    r   async_gen_wrapperCAsyncGenTest.test_async_gen_exception_11.<locals>.async_gen_wrapperp  s^     G+C))D/!!jj111 G "1  sD   !A,AA,A AA A,A A)&A,(A))A,Nr   )rD   r   r   rl   rk   s   &  @@r   test_async_gen_exception_11(AsyncGenTest.test_async_gen_exception_11]  s1    				 	 0 24E4GHr   c                  a aa VVV 3R  loS! 4       oSP                  4       pVP                  4       pS P                  \        R4      ;_uu_ 4        VP	                  4        RRR4       S P                  \        R4      ;_uu_ 4        VP                  R4       RRR4       R#   + '       g   i     LJ; i  + '       g   i     R# ; i)c                    <"   SP                  \        R S P                   R24      ;_uu_ 4        \        S4      G Rj  xL
  RRR4       ^{5x  R#  L  + '       g   i     L; i5i)coroutine method 'asend' of '' was never awaitedN)assertWarnsRegexRuntimeWarningr   anext)r)   merD   s   r   r)   5AsyncGenTest.test_async_gen_exception_12.<locals>.gen}  s\     &&~3C4D4D3E F( )* * Bi* I  * *s-   -A(AA AA(AA%	 A(4anext\(\): asynchronous generator is already runningN4cannot reuse already awaited __anext__\(\)/asend\(\))r   r1   r@   r   r`   r   )rD   r   rg   r)   r   s   f  @@r   test_async_gen_exception_12(AsyncGenTest.test_async_gen_exception_12|  s    	 U\\^\\^##LGI IKKMI ##LGI IGGDMI I	I II I Is   B$B7$B4	7C	c                  aa ^ RI pVP                  R 4       o ! R R\        4      oVV3R lpV! 4       pVP                  R4      pVP	                  R4       VP                  R4      pV P                  \        R4      ;_uu_ 4        VP                  S4       RRR4       V P                  \        R4      ;_uu_ 4        VP	                  R4       RRR4       R#   + '       g   i     LJ; i  + '       g   i     R# ; i)r   Nc              3      "   V x # 5ir$   r
   vs   &r   _async_yieldRAsyncGenTest.test_async_gen_asend_throw_concurrent_with_send.<locals>._async_yield       G   c                       ] tR tRtRtR# )KAsyncGenTest.test_async_gen_asend_throw_concurrent_with_send.<locals>.MyExci  r
   Nr   r
   r   r   MyExcr         r   r   c                 T   <"     S! R4      G Rj  xL
  K   L  S  d     K   i ; i5iTNr
   r   r   s   r   agenfnLAsyncGenTest.test_async_gen_asend_throw_concurrent_with_send.<locals>.agenfn  -     &t,,, (   (  ( %(%(r   r   )types	coroutinera   r   r   r@   r   r   rD   r   r   agenr)   gen2r   r   s   &     @@r   /test_async_gen_asend_throw_concurrent_with_send<AsyncGenTest.test_async_gen_asend_throw_concurrent_with_send  s    		 
		I 		 xjjzz$##LGI IJJuI ##LGI IIIdOI I	I II I I   C?C.C+	.C?	c                  aa ^ RI pVP                  R 4       o ! R R\        4      oVV3R lpV! 4       pVP                  R4      pVP	                  R4       VP                  S4      pV P                  \        R4      ;_uu_ 4        VP                  S4       RRR4       V P                  \        R4      ;_uu_ 4        VP	                  R4       RRR4       R#   + '       g   i     LJ; i  + '       g   i     R# ; i)r   Nc              3      "   V x # 5ir$   r
   r   s   &r   r   SAsyncGenTest.test_async_gen_athrow_throw_concurrent_with_send.<locals>._async_yield  r   r   c                       ] tR tRtRtR# )LAsyncGenTest.test_async_gen_athrow_throw_concurrent_with_send.<locals>.MyExci  r
   Nr   r
   r   r   r   r	    r   r   r   c                 T   <"     S! R4      G Rj  xL
  K   L  S  d     K   i ; i5ir   r
   r   s   r   r   MAsyncGenTest.test_async_gen_athrow_throw_concurrent_with_send.<locals>.agenfn  r   r   5athrow\(\): asynchronous generator is already running2cannot reuse already awaited aclose\(\)/athrow\(\))	r   r   ra   r   r   r   r@   r   r   r   s   &     @@r   0test_async_gen_athrow_throw_concurrent_with_send=AsyncGenTest.test_async_gen_athrow_throw_concurrent_with_send  s    		 
		I 		 xjj{{5!##LHJ JJJuJ ##LEG GIIdOG G	J JG G Gr  c                  aa ^ RI pVP                  R 4       o ! R R\        4      oVV3R lpV! 4       pV P                  \        4      ;_uu_ 4        VP                  R4      P                  R4       RRR4       VP                  S4      pVP                  S4       VP                  S4      pV P                  \        R4      ;_uu_ 4        VP                  S4       RRR4       V P                  \        R4      ;_uu_ 4        VP                  R4       RRR4       R#   + '       g   i     L; i  + '       g   i     L]; i  + '       g   i     R# ; i)r   Nc              3      "   V x # 5ir$   r
   r   s   &r   r   SAsyncGenTest.test_async_gen_asend_throw_concurrent_with_throw.<locals>._async_yield  r   r   c                       ] tR tRtRtR# )LAsyncGenTest.test_async_gen_asend_throw_concurrent_with_throw.<locals>.MyExci  r
   Nr   r
   r   r   r   r    r   r   r   c                 z   <"    R 5x    S! R 4      G R j  xL
  K    S  d     Li ; i L  S  d     K-  i ; i5ir$   r
   r   s   r   r   MAsyncGenTest.test_async_gen_asend_throw_concurrent_with_throw.<locals>.agenfn  P      &t,,,	   - @   ; ;- +- ;(;(;- 8;8;r   r   r   r   ra   r   r   r   r   r   r   r@   r   r   s   &     @@r   0test_async_gen_asend_throw_concurrent_with_throw=AsyncGenTest.test_async_gen_asend_throw_concurrent_with_throw  s   		 
		I 			 x}--JJt!!$' . kk% 		%zz% ##LGI IJJuI ##LGI IIIdOI I .-I II I I$   !D!D4E!D1	4E	E	c                  aa ^ RI pVP                  R 4       o ! R R\        4      oVV3R lpV! 4       pV P                  \        4      ;_uu_ 4        VP                  R4      P                  R4       RRR4       VP                  S4      pVP                  S4       VP                  R4      pV P                  \        R4      ;_uu_ 4        VP                  S4       RRR4       V P                  \        R4      ;_uu_ 4        VP                  R4       RRR4       R#   + '       g   i     L; i  + '       g   i     L]; i  + '       g   i     R# ; i)r   Nc              3      "   V x # 5ir$   r
   r   s   &r   r   TAsyncGenTest.test_async_gen_athrow_throw_concurrent_with_throw.<locals>._async_yield  r   r   c                       ] tR tRtRtR# )MAsyncGenTest.test_async_gen_athrow_throw_concurrent_with_throw.<locals>.MyExci  r
   Nr   r
   r   r   r   r!    r   r   r   c                 z   <"    R 5x    S! R 4      G R j  xL
  K    S  d     Li ; i L  S  d     K-  i ; i5ir$   r
   r   s   r   r   NAsyncGenTest.test_async_gen_athrow_throw_concurrent_with_throw.<locals>.agenfn  r  r  r  r  r  r   s   &     @@r   1test_async_gen_athrow_throw_concurrent_with_throw>AsyncGenTest.test_async_gen_athrow_throw_concurrent_with_throw  s   		 
		I 			 x}--JJt!!$' . kk% 		%{{4 ##LHJ JJJuJ ##LEG GIIdOG G .-J JG G Gr  c                r   R  pV P                  \        4      ;_uu_ 4        V! 4       P                  \        \        4       R4      pRRR4       V P	                  \        4      ;_uu_ 4        XP                  R4       ?\        4        RRR4       R#   + '       g   i     LT; i  + '       g   i     R# ; i)c                    "   ^{5x  R# 5ir   r
   r
   r   r   r)   BAsyncGenTest.test_async_gen_3_arg_deprecation_warning.<locals>.gen  r   r   N)assertWarnsDeprecationWarningr   r   r   r   r   )rD   r)   xs   &  r   (test_async_gen_3_arg_deprecation_warning5AsyncGenTest.test_async_gen_3_arg_deprecation_warning  su    	 011]MOTBA 2}--FF4LL .- 21---s   %B+B%B"	%B6	c                   R  pV! 4       pV P                  VP                  R4       RVn        V P                  VP                  R4       V P                  RVP                  4       RVn        V P                  VP                  R4       V P	                  VP
                  4       V P                  VP                  \        P                  4       V P                  VP                  4       V P                  VP                  \        P                  4       VP                  4       pV P                  \         P"                  ! V4      4       VP%                  4        R# )c                    "   ^{5x  R# 5ir   r
   r
   r   r   r)   /AsyncGenTest.test_async_gen_api_01.<locals>.gen)  r   r   r)   123z.genN)rj   r   assertInr   assertIsNoneag_awaitassertIsInstanceag_framer   	FrameTyper   
ag_runningag_codeCodeTypeaclose
assertTrueinspectisawaitableclose)rD   r)   rc   r;  s   &   r   test_async_gen_api_01"AsyncGenTest.test_async_gen_api_01(  s    	 EU+
U+fann-/!**%ajj%//:&aii8++F34r   c                (  a ^ RI pVP                  R 4       oV3R lpV! 4       pVP                  R4      pVP                  R4       V P	                  \
        R4      ;_uu_ 4        VP                  4        RRR4       R#   + '       g   i     R# ; i)r   Nc              3      "   V x # 5ir$   r
   r   s   &r   r   KAsyncGenTest.test_async_gen_asend_close_runtime_error.<locals>._async_yieldA  r   r   c                 |   <"    S ! R 4      G R j  xL
  R #  L  \          d    S ! R 4      G R j  xL 
   R # i ; i5ir$   r   r   s   r   r   EAsyncGenTest.test_async_gen_asend_close_runtime_error.<locals>.agenfnE  sB     )"4(((  )  )"4((()s0   <  < 929<9<coroutine ignored GeneratorExit)r   r   r   r   r@   r   r?  )rD   r   r   r   r)   r   s   &    @r   (test_async_gen_asend_close_runtime_error5AsyncGenTest.test_async_gen_asend_close_runtime_error>  sp    		 
		 xjj##L2STTIIK UTTTs   %B  B	c                  aa ^ RI pVP                  R 4       o ! R R\        4      oVV3R lpV! 4       pV P                  \        4      ;_uu_ 4        VP                  R4      P                  R4       RRR4       VP                  S4      pVP                  R4       V P                  \        R4      ;_uu_ 4        VP                  4        RRR4       R#   + '       g   i     Lk; i  + '       g   i     R# ; i)r   Nc              3      "   V x # 5ir$   r
   r   s   &r   r   LAsyncGenTest.test_async_gen_athrow_close_runtime_error.<locals>._async_yieldV  r   r   c                       ] tR tRtRtR# )EAsyncGenTest.test_async_gen_athrow_close_runtime_error.<locals>.MyExciZ  r
   Nr   r
   r   r   r   rP  Z  r   r   r   c                    <"    R 5x  R #   S  d;     S! R 4      G R j  xL 
   R #   \          d    S! R 4      G R j  xL 
    R # i ; ii ; i5ir$   rF  r   s   r   r   FAsyncGenTest.test_async_gen_athrow_close_runtime_error.<locals>.agenfn]  sL     - --&t,,,$ -&t,,,--sQ   A AA("(AA	AA	AAA		AArI  )r   r   ra   r   r   r   r   r   r@   r   r?  )rD   r   r   r   r)   r   r   s   &    @@r   )test_async_gen_athrow_close_runtime_error6AsyncGenTest.test_async_gen_athrow_close_runtime_errorS  s    		 
		I 		- x}--JJt!!$' .kk% ##L2STTIIK UT	 .- UTTs   !C<C*C'	*C;	r
   N)r   r   r   r   ro   rz   r   r   r   r   r   r   r   r   r   r   r   r  r  r  r$  r,  r@  rJ  rS  r   rX   rY   s   @r   r\   r\      sy     ) V
:;:&*9.9292(I>(BB$L#J	,* r   r\   c                     a  ] tR tRt o R tR tR tR tR tR t	R t
R	 tR
 tR tR tR tR tR tR tR tR tR tR tR tR tR tR tR tR tR tR tR tR t R t!R  t"R! t#R" t$R# t%R$ t&R% t'R& t(R' t)R( t*R) t+R* t,R+ t-R, t.R- t/R. t0R/ t1R0 t2R1 t3R2 t4R3 t5R4 t6R5 t7R6 t8R7 t9R8 t:R9 t;R: t<R; t=R< t>R= t?R>t@V tAR?# )@AsyncGenAsyncioTestio  c                b    \         P                  4       V n        \         P                  R 4       R # r$   )r   new_event_looploopset_event_looprD   s   &r   setUpAsyncGenAsyncioTest.setUpq  s     **,	t$r   c                    V P                   P                  4        R V n         \        P                  P	                  R 4       R # r$   )rY  r?  r   events_set_event_loop_policyr[  s   &r   tearDownAsyncGenAsyncioTest.tearDownu  s)    			--d3r   c                8   V P                  R R7      ;_uu_ 4        V P                  V\        4       RRR4       V P                  RR7      ;_uu_ 4        V P                  V\        4       RRR4       R#   + '       g   i     LK; i  + '       g   i     R# ; i)zpure-Pythonr   Nbuiltin)subTest_check_async_iterator_anextr:   r   )rD   	ait_classs   &&r   check_async_iterator_anext.AsyncGenAsyncioTest.check_async_iterator_anextz  sd    \\\..,,YA /\\	\**,,Y> +* /.***s   A5B5B	B	c                J  a aaa	 S! 4       o	VV	3R  lpS P                   P                  V! 4       4      pS P                  V. RO4       S P                  \        4      ;_uu_ 4        S P                   P                  V! 4       4       RRR4       VVV 3R lpS P                   P                  V! 4       4      pS P                  VR4       VVV 3R lpV! 4        VVV 3R lpS P                   P                  V! 4       4      pS P                  VR4       R#   + '       g   i     L; i)c                     <"   . p T P                  S! S4      G R j  xL
 4       T P                  S! S4      G R j  xL
 4       T P                  S! SR4      G R j  xL
 4       V #  LI L, L5i)Nbuckle my shoer%   )resultsr   rc   s    r   consume@AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.consume  sV     GNNq>*NNq>*NNq*:!;;<N *);s1   A,A&A,A(A,A*A,(A,*A,Nc                    <"   S! 4       p SP                  S! V 4      G R j  xL
 ^4       SP                  S! V 4      G R j  xL
 ^4       SP                  \        4      ;_uu_ 4        S! V 4      G R j  xL
  R R R 4       SP                  \        4      ;_uu_ 4        S! V 4      G R j  xL
  R R R 4       S! 4       pSP                  S! VR4      G R j  xL
 ^4       SP                  S! VR4      G R j  xL
 ^4       SP                  S! VR4      G R j  xL
 R4       SP                  S! VR4      G R j  xL
 R4       R#  EL# EL L  + '       g   i     L; i L  + '       g   i     L; i L L L` LA5iNr2   	completed)rj   r   r0   )g1g2rh  r   rD   s     r   test_2?AsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_2  s!    B59_a059_a0""#566Bi 7""#566Bi 7 B5Y#77;5Y#77;5Y#77C5Y#77C -, 76   76 8777s   E<EE<E&E<(E4E
5E9%E<E!*E+E!/&E<E4 E<6E67 E<E8 E<8E:9E<E<
EE	E<E!!E1	,	E<6E<8E<:E<rs  c            	      N  < S! 4       p S! V R 4      pSP                  \        4      ;_uu_ 4        \        P                  ! VP	                  4       4      ;_uu_ 4       pVP                  R4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)rs  N)r   r   
contextlibclosing	__await__r   )pobjrc   rh  r   rD   s      r   	test_sendBAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_send  sk    A;'C""=11''88AFF4L 9 2188 211s#   -BB 	.B BBB$	c                  z   <"   S! 4       p S! V R 4      pSP                  \        VP                  \        4       R # 5i)rs  )r   rA   r   )r|  r}  rh  r   rD   s     r   
test_throwCAsyncGenAsyncioTest._check_async_iterator_anext.<locals>.test_throw  s2     A;'Ck399kBs   8;)r      rm  )rY  r!   rj   r   r0   )
rD   rh  r   ro  r'   rv  r   r~  r  rc   s
   fff      @r   rg  /AsyncGenAsyncioTest._check_async_iterator_anext  s    K	 ii**79567122II((3 3	" --fh7-	! 		 --jl;-O 32s   $!DD"	c                .    R  pV P                  V4       R# )c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   r   <AsyncGenAsyncioTest.test_async_generator_anext.<locals>.agen       GGr   Nri  )rD   r   s   & r   test_async_generator_anext.AsyncGenAsyncioTest.test_async_generator_anext  s    	 	''-r   c                <     ! R  R4      pV P                  V4       R# )c                   6   a  ] tR tRt o RtR tR tR tRtV t	R# )IAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIteri  Asynchronously yield 1, then 2.c                    ^ V n         R# r   Nyieldedr[  s   &r   __init__RAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__init__  	     r   c                    V # r$   r
   r[  s   &r   r   SAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__aiter__      r   c                   "   V P                   ^8  d   \        4       hV ;P                   ^,          un         V P                   # 5ir  r  r0   r[  s   &r   r1   SAsyncGenAsyncioTest.test_python_async_iterator_anext.<locals>.MyAsyncIter.__anext__  s2     <<1$,..LLA%L<<'s   AAr  N)
r   r   r   r   __doc__r  r   r1   r   rX   rY   s   @r   MyAsyncIterr    s     1!( (r   r  Nr  )rD   r  s   & r    test_python_async_iterator_anext4AsyncGenAsyncioTest.test_python_async_iterator_anext  s    	( 	( 	''4r   c                L   a ^ RI o ! V3R lR4      pV P                  V4       R# )r   Nc                   X   <a  ] tR tRt o RtR tR t ZP                  R 4       tRt	V t
R# )fAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoroi  r  c                    ^ V n         R# r  r  r[  s   &r   r  oAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__init__  r  r   c                    V # r$   r
   r[  s   &r   r   pAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__aiter__  r  r   c              3     "    T P                   ^8  d   \        4       hT ;P                   ^,          un         T P                   # 5i)Fr  r[  s   &r   r1   pAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext.<locals>.MyAsyncIterWithTypesCoro.__anext__  s5     <<1$,..LLA%L<<'s   AAr  N)r   r   r   r   r  r  r   r   r1   r   rX   )rZ   r   s   @r   MyAsyncIterWithTypesCoror    s(     1!__( (r   r  )r   ri  )rD   r  r   s   & @r   0test_python_async_iterator_types_coroutine_anextDAsyncGenAsyncioTest.test_python_async_iterator_types_coroutine_anext  s!    	( 	( 	''(@Ar   c                   a R  pV! 4       oV3R lpV P                   P                  V! 4       4      pV P                  V^^.4       R# )c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   r)   5AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.gen  r  r   c                  X   <"   \        S4       U u. u R j  xL
 q NK   LDup # u up i 5ir$   aiter)r(   rc   s    r   ro  9AsyncGenAsyncioTest.test_async_gen_aiter.<locals>.consume  s!     %*1X..A...s$   *%!
!%!%*NrY  r!   rj   )rD   r)   ro  r'   rc   s   &   @r   test_async_gen_aiter(AsyncGenAsyncioTest.test_async_gen_aiter  s@    	 E	/ii**795q!f%r   c                   aa . o ! R  R4      pV! 4       oVV3R lpV P                   P                  V! 4       4       V P                  S^^.4       R# )c                   &   a  ] tR tRt o R tRtV tR# );AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Geni  c               "   "   ^5x  ^5x  R# 5ir   r
   r[  s   &r   r   EAsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.Gen.__aiter__  s     r   r
   Nr   r   r   r   r   r   rX   rY   s   @r   Genr    s      r   r  c                     <"   \        S4      p   SP                  \        V 4      G Rj  xL
 4       K&   L
  \         d     R# i ; i5ir   )r  r&   r   r0   )aitrc   rn  s    r   ro  ?AsyncGenAsyncioTest.test_async_gen_aiter_class.<locals>.consume  s>     (CNNs#34#3) s1   A	7 57 A	7 AA	AA	Nr  )rD   r  ro  rc   rn  s   &  @@r   test_async_gen_aiter_class.AsyncGenAsyncioTest.test_async_gen_aiter_class  sJ    	 	 E	 			$$WY/1a&)r   c                d    R  p\        V! 4       4      p\        V4      pV P                  W#4       R# )c                    "   ^5x  R# 5ir   r
   r
   r   r   r)   6AsyncGenAsyncioTest.test_aiter_idempotent.<locals>.gen  
     Gr   N)r  ru   )rD   r)   applied_onceapplied_twices   &   r   test_aiter_idempotent)AsyncGenAsyncioTest.test_aiter_idempotent  s(    	SU|l+l2r   c                  a R  oR pV3R lpV3R lpV3R lpV P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       V P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       V P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       V P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       R#   + '       g   i     L; i  + '       g   i     L; i  + '       g   i     L~; i  + '       g   i     R# ; i)c                    "   ^5x  R# 5ir   r
   r
   r   r   r)   4AsyncGenAsyncioTest.test_anext_bad_args.<locals>.gen  r  r   c                  6   "   \        4       G R j  xL
  R #  L5ir$   rd  r
   r   r   call_with_too_few_argsGAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_few_args        'MM   c                  H   <"   \        S ! 4       ^^4      G Rj  xL
  R#  L5ir   rd  r)   s   r   call_with_too_many_argsHAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_too_many_args  s     q!$$$s   " "c                  F   <"   \        ^S ! 4       4      G Rj  xL
  R#  L5ir   rd  r  s   r   call_with_wrong_type_argsJAsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_wrong_type_args  s     35/!!   !!c                  F   <"   \        S ! 4       R 7      G Rj  xL
  R#  L5i))	aiteratorNrd  r  s   r   call_with_kwarg@AsyncGenAsyncioTest.test_anext_bad_args.<locals>.call_with_kwarg  s     #%(((r  Nr   r8   rY  r!   )rD   r  r  r  r  r)   s   &    @r   test_anext_bad_args'AsyncGenAsyncioTest.test_anext_bad_args  s    			%	"	)y))II(()?)AB *y))II(()@)BC *y))II(()B)DE *y))II(():; *) *))))))))s/   !D4=!E!E	!E-4E	E	E*	-E>	c                x   a  V 3R  lpS P                   P                  V! 4       4      pS P                  VR4       R# )c                    <a"    ! R  R4      o ! V3R lR4      p Rp\        V ! 4       R4      pSP                  \        V4      ;_uu_ 4        VG Rj  xL
  RRR4       \        V ! 4       4      pSP                  \        V4      ;_uu_ 4        VG Rj  xL
  RRR4       R#  LO  + '       g   i     LU; i L#  + '       g   i     R# ; i5i)c                   &   a  ] tR tRt o R tRtV tR# )UAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitablei  c                    ^*# )*   r
   r[  s   &r   r{  _AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.BadAwaitable.__await__  s    r   r
   Nr   r   r   r   r{  r   rX   rY   s   @r   BadAwaitabler    s      r   r  c                   4   <a  ] tR tRt o R tV3R ltRtV tR# )TAsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIteri  c                    V # r$   r
   r[  s   &r   r   ^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__aiter__  s    Kr   c                   < S! 4       # r$   r
   )rD   r  s   &r   r1   ^AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable.<locals>.MyAsyncIter.__anext__  s    '>)r   r
   Nr   r   r   r   r   r1   r   rX   )rZ   r  s   @r   r  r    s      * *r   r  z__await__.*iteratorr2   Nrs  )r   r@   r8   )r  regexr   r  rD   s      @r   bad_awaitable?AsyncGenAsyncioTest.test_anext_bad_await.<locals>.bad_awaitable  s      * *
 +EkmY7I''	599 :km,I''	599 :	   :9   :9sZ   A	CB%B#B%6CB:B8B:
C#B%%B5	0C8B::C		Crs  Nr  )rD   r  r   s   f  r   test_anext_bad_await(AsyncGenAsyncioTest.test_anext_bad_await  s0    	" --mo>-r   c                f  "   \        V! 4       R 4      pV P                  \        4      ;_uu_ 4        VG Rj  xL
  RRR4       \        V! 4       4      pV P                  \        4      ;_uu_ 4        VG Rj  xL
  RRR4       R#  LN  + '       g   i     LT; i L#  + '       g   i     R# ; i5i)r2   Nrs  )r   r   r8   )rD   aiter_classr   s   && r   check_anext_returning_iterator2AsyncGenAsyncioTest.check_anext_returning_iterator&  sz     +-3	y))OO *+-(	y))OO *	  *)  *)sU   /B1BBB5B11B7B8B<
B1BB	B1BB.	(	B1c                     ! R  R4      pV P                   P                  V P                  V4      4      pV P                  VR4       R# )c                   ,   a  ] tR tRt o R tR tRtV tR# )EAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnexti0  c                    V # r$   r
   r[  s   &r   r   OAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__aiter__1  r  r   c                    \        R 4      # )abc)iterr[  s   &r   r1   OAsyncGenAsyncioTest.test_anext_return_iterator.<locals>.WithIterAnext.__anext__3  s    E{"r   r
   Nr  rY   s   @r   WithIterAnextr  0  s     # #r   r  rs  NrY  r!   r  rj   )rD   r  r   s   &  r   test_anext_return_iterator.AsyncGenAsyncioTest.test_anext_return_iterator/  s>    	# 	#
 --d.Q.QR_.`a-r   c                     ! R  R4      pV P                   P                  V P                  V4      4      pV P                  VR4       R# )c                   ,   a  ] tR tRt o R tR tRtV tR# )EAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnexti9  c                    V # r$   r
   r[  s   &r   r   OAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__aiter__:  r  r   c              3     "   R x  R # 5ir$   r
   r[  s   &r   r1   OAsyncGenAsyncioTest.test_anext_return_generator.<locals>.WithGenAnext.__anext__<  s     s   	r
   Nr  rY   s   @r   WithGenAnextr  9  s      r   r  rs  Nr  )rD   r  r   s   &  r   test_anext_return_generator/AsyncGenAsyncioTest.test_anext_return_generator8  s>    	 	
 --d.Q.QR^._`-r   c                   a aa  ! R  R4      o ! V3R lR4      oVV 3R lpS P                   P                  V! 4       4      pS P                  VR4       R# )c                   &   a  ] tR tRt o R tRtV tR# )EAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitableiB  c              3     "   \        4       h5ir$   r   r[  s   &r   r{  OAsyncGenAsyncioTest.test_anext_await_raises.<locals>.RaisingAwaitable.__await__C  s     '))r   r
   Nr  rY   s   @r   RaisingAwaitabler  B  s      r   r  c                   4   <a  ] tR tRt o R tV3R ltRtV tR# )NAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnextiF  c                    V # r$   r
   r[  s   &r   r   XAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__aiter__G  r  r   c                   < S! 4       # r$   r
   )rD   r  s   &r   r1   XAsyncGenAsyncioTest.test_anext_await_raises.<locals>.WithRaisingAwaitableAnext.__anext__I  s    '))r   r
   Nr  )rZ   r  s   @r   WithRaisingAwaitableAnextr  F  s     * *r   r   c                  h  <"   \        S! 4       4      p SP                  \        4      ;_uu_ 4        V G R j  xL
  R R R 4       \        S! 4       R4      p SP                  \        4      ;_uu_ 4        V G R j  xL
  R R R 4       R#  LO  + '       g   i     LU; i L#  + '       g   i     R# ; i5irr  )r   r   r   )r   r   rD   s    r   do_test<AsyncGenAsyncioTest.test_anext_await_raises.<locals>.do_testK  s     79:I""#455 6799EI""#455 6	   65   65sU   .B2B	BB	6B22B8B9B=
B2B		B	B2BB/	)	B2rs  Nr  )rD   r"  r   r  r   s   f  @@r   test_anext_await_raises+AsyncGenAsyncioTest.test_anext_await_raisesA  sD    	 		* 	*
	 --gi8-r   c                *  a aa	a
 \         P                  R  4       o	 ! R R\        4      oVV	3R lo
VV
V 3R lpVV
V 3R lpV
V 3R lpVV 3R lpVV 3R lpVV 3R	 lpV 3R
 lpV! V4       V! V4       V! V4       V! V4       V! V4       V! V4       R# )c              3      "   V x # 5ir$   r
   r   s   &r   r   9AsyncGenAsyncioTest.test_anext_iter.<locals>._async_yieldW  r   r   c                       ] tR tRtRtR# )4AsyncGenAsyncioTest.test_anext_iter.<locals>.MyErrori[  r
   Nr   r
   r   r   MyErrorr*  [  r   r   r+  c                 t   <"    S! ^4      G Rj  xL
  R#  L  S  d    S! ^4      G Rj  xL 
   R# i ; i5ir   r
   r+  r   s   r   r   3AsyncGenAsyncioTest.test_anext_iter.<locals>.agenfn^  s@     &"1o%%  & &"1o%%&0   8  8 5.5858c                   < S! 4       p\         P                  ! V ! VR 4      P                  4       4      ;_uu_ 4       pSP                  VP	                  R4      ^4       SP                  VP                  S! 4       4      ^4        VP	                  R4       SP                  R4       SP                  XP                  R 4       RRR4       R#   \         d   pTp Rp?L8Rp?ii ; i  + '       g   i     R# ; i)r2   Nr   )	ry  rz  r{  rj   r   r   r   r   value)r   r   rc   eerrr+  r   rD   s   &    r   test12AsyncGenAsyncioTest.test_anext_iter.<locals>.test1f  s    8D##E$	$:$D$D$FGG1  q1  !3Q7>FF4L II<=  I6 HG
 % C HGGs6   AC'C-C'C$CC'C$$C''C8	c           	        < S! 4       p\         P                  ! V ! VR 4      P                  4       4      ;_uu_ 4       pSP                  VP	                  R4      ^4       SP                  VP                  S! 4       4      ^4       SP                  S4      ;_uu_ 4        VP                  S! 4       4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)r2   N)ry  rz  r{  rj   r   r   r   )r   r   rc   r+  r   rD   s   &  r   test22AsyncGenAsyncioTest.test_anext_iter.<locals>.test2s  s    8D##E$	$:$D$D$FGG1  q1  !3Q7&&w//GGGI& 0 HG 0/ HGGs$   A!CC	4CCCC*	c           	        < S! 4       p\         P                  ! V ! VR 4      P                  4       4      ;_uu_ 4       pSP                  VP	                  R4      ^4       VP                  4        SP                  \        R4      ;_uu_ 4        SP                  VP	                  R4      ^4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)r2   Nzcannot reuse)ry  rz  r{  rj   r   r?  r@   r   )r   r   rc   r   rD   s   &  r   test32AsyncGenAsyncioTest.test_anext_iter.<locals>.test3{  s    8D##E$	$:$D$D$FGG1  q1	++L.II$$QVVD\15 J HG JI HGGs$   AC"C 	.C CCC$	c           	        <a \         P                  R  4       oVV3R lpV! 4       p\        P                  ! V ! VR4      P	                  4       4      ;_uu_ 4       pSP                  VP                  R4      ^
4       SP                  VP                  S! 4       4      ^4       SP                  SR4      ;_uu_ 4        VP                  S! R4      4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)c              3   D   "   V ^
,          x  V ^
,          ^,           x # 5ir   r
   r   s   &r   r   HAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>._async_yield       "f 2vz*+    c                 t   <"    S! ^4      G Rj  xL
  R#  L  S  d    S! ^4      G Rj  xL 
   R# i ; i5ir   r
   r-  s   r   r   BAsyncGenAsyncioTest.test_anext_iter.<locals>.test4.<locals>.agenfn  s@     *&q/))  * *&q/))*r/  r2   Nval)	r   r   ry  rz  r{  rj   r   r   r@   r   r   r   rc   r   r+  rD   s   &   @r   test42AsyncGenAsyncioTest.test_anext_iter.<locals>.test4  s    __, , 8D##E$	$:$D$D$FGG1  r2  !3R8++GU;;GGGEN+ < HG <; HGGs%   A"C9<C&	C9&C61C99D
	c           	        <a \         P                  R  4       oVV3R lpV! 4       p\        P                  ! V ! VR4      P	                  4       4      ;_uu_ 4       pSP                  VP                  R4      ^
4       SP                  \        R4      ;_uu_ 4        VP                  S! 4       4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)c              3   D   "   V ^
,          x  V ^
,          ^,           x # 5ir>  r
   r   s   &r   r   HAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>._async_yield  r@  rA  c                 \   <"    S! ^4      G Rj  xL
  R5x  R#  L  S  d     R# i ; i5ir   Naaar
   r-  s   r   r   BAsyncGenAsyncioTest.test_anext_iter.<locals>.test5.<locals>.agenfn  s5     &q/))  * s(   ,  , ),),r2   N)
r   r   ry  rz  r{  rj   r   r@   r   r   rE  s   &   @r   test52AsyncGenAsyncioTest.test_anext_iter.<locals>.test5  s    __, , 8D##E$	$:$D$D$FGG1  r2++M9EEGGGI& F HGEE HGGs%   A CC	1CCCC'	c           	        <a \         P                  R  4       oV3R lpV! 4       p\        P                  ! V ! VR4      P	                  4       4      ;_uu_ 4       pSP                  S4      ;_uu_ 4        VP                  S! 4       4       RRR4       RRR4       R#   + '       g   i     L; i  + '       g   i     R# ; i)c              3   D   "   V ^
,          x  V ^
,          ^,           x # 5ir>  r
   r   s   &r   r   HAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>._async_yield  r@  rA  c                 >   <"   S ! ^4      G Rj  xL
  R5x  R#  L5irL  r
   rG  s   r   r   BAsyncGenAsyncioTest.test_anext_iter.<locals>.test6.<locals>.agenfn  s     "1o%% &s   r2   N)r   r   ry  rz  r{  r   r   rE  s   &   @r   test62AsyncGenAsyncioTest.test_anext_iter.<locals>.test6  s    __, , 8D##E$	$:$D$D$FGG1&&w//GGGI& 0 HG// HGGs$   B/3B	
B/B,'B//C 	c                   < SP                  R 4      ;_uu_ 4        V ! \        4       RRR4       SP                  R4      ;_uu_ 4        V ! \        4       RRR4       R#   + '       g   i     L@; i  + '       g   i     R# ; i)zpure-Python anext()Nzbuiltin anext())rf  r:   r   )testrD   s   &r   run_test5AsyncGenAsyncioTest.test_anext_iter.<locals>.run_test  sQ    344X 5/00U 10 54000s   A 	A3 A0	3B	N)r   r   ra   )rD   r4  r7  r:  rF  rO  rV  rZ  r+  r   r   s   f       @@@r   test_anext_iter#AsyncGenAsyncioTest.test_anext_iterV  sy    		 
		i 			7	'	6	,*	'&	'	 	r   c                >  a R  oR pV3R lpR pV P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       V P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       V P                  \        4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       R#   + '       g   i     L; i  + '       g   i     Lk; i  + '       g   i     R# ; i)c                    "   ^5x  R# 5ir   r
   r
   r   r   r)   4AsyncGenAsyncioTest.test_aiter_bad_args.<locals>.gen  r  r   c                  6   "   \        4       G R j  xL
  R #  L5ir$   r  r
   r   r   r  GAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_few_args  r  r  c                  F   <"   \        S ! 4       ^4      G Rj  xL
  R#  L5ir   r  r  s   r   r  HAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_too_many_args  s     q/!!r  c                  8   "   \        ^4      G Rj  xL
  R#  L5ir   r  r
   r   r   call_with_wrong_type_argIAsyncGenAsyncioTest.test_aiter_bad_args.<locals>.call_with_wrong_type_arg  s     (NNs   Nr  )rD   r  r  rf  r)   s   &   @r   test_aiter_bad_args'AsyncGenAsyncioTest.test_aiter_bad_args  s    			"	y))II(()?)AB *y))II(()@)BC *y))II(()A)CD *)	 *))))))s#   !C%4!C8:!D%C5	8D	D	c                V   "   . pV  R j  xL
  pVP                  V4       K   LDT# 5ir$   r%   )rD   r)   r'   r(   s   &&  r   r,   AsyncGenAsyncioTest.to_list  s0      	 	!JJqM	s
s   )&$&)&)c                    R  pV P                   P                  V P                  V! 4       4      4      pV P                  V^^.4       R# )c                    "   ^5x  \         P                  R4      G Rj  xL
  ^5x  \         P                  R4      G Rj  xL
  R#  L( L5ir   {Gz?Nr   sleepr
   r   r   r)   :AsyncGenAsyncioTest.test_async_gen_asyncio_01.<locals>.gen  s>     G--%%%G--%%% &%s!   AA	!AAAANrY  r!   r,   rj   )rD   r)   r'   s   &  r   test_async_gen_asyncio_01-AsyncGenAsyncioTest.test_async_gen_asyncio_01  s<    	 ii**4<<+>?q!f%r   c                    R  pV P                  \        4      ;_uu_ 4        V P                  P                  V P	                  V! 4       4      4       RRR4       R#   + '       g   i     R# ; i)c                 |   "   ^5x  \         P                  R4      G Rj  xL
  ^5x  ^^ ,           ^5x  R#  L5irn  rp  r
   r   r   r)   :AsyncGenAsyncioTest.test_async_gen_asyncio_02.<locals>.gen  s2     G--%%%GEG &s   <:<N)r   r   rY  r!   r,   ry   s   & r   test_async_gen_asyncio_02-AsyncGenAsyncioTest.test_async_gen_asyncio_02  sG    	 011II((ce)<= 2111s   0AA,	c                    V P                   p ! R  R4      pVP                  V P                  V! 4       4      4      pV P                  V^^.4       R# )c                   &   a  ] tR tRt o R tRtV tR# ):AsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Geni  c               `   "   ^5x  \         P                  R4      G Rj  xL
  ^5x  R#  L5irn  rp  r[  s   &r   r   DAsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Gen.__aiter__  s&     mmD))) *s   .,.r
   Nr  rY   s   @r   r  r}    s      r   r  Nrs  )rD   rY  r  r'   s   &   r   test_async_gen_asyncio_03-AsyncGenAsyncioTest.test_async_gen_asyncio_03  sF    yy	 	 %%dll35&9:q!f%r   c                   a a R  oVV 3R lpVV 3R lpS P                   P                  V! 4       4       S P                   P                  V! 4       4       R# )c                    "   ^5x  \         P                  R4      G Rj  xL
   ^5x  ^5x  \         P                  R4      G Rj  xL
  ^5x  R#  L3  \         d	    R5x   L8i ; i L#5ir   ro  N  )r   rq  r   r
   r   r   foo@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.foo  sb     G--%%% --%%%G & % 
%s=   A.AA.
A A.A,	A.A)&A.(A))A.c                    <"   S! 4       P                  4       p SP                  V P                  4       G R j  xL
 ^4       SP                  V P                  4       G R j  xL
 ^4       SP                  V P                  4       G R j  xL
 ^4       SP                  V P                  4       G R j  xL
 ^4       SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       R #  L L L L LT  + '       g   i     LZ; i L+  + '       g   i     R # ; i5ir$   )r   rj   r1   r   r0   )itr  rD   s    r   run1AAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run1  s     "B2<<>1152<<>1152<<>1152<<>115""#566lln$$ 7""#566lln$$ 76 2111$ 76 % 766s   4E*D7'E*D9 'E*D;'E*/D=0&E*E*D?+E/%E*E(E)E-E*9E*;E*=E*?EE	E*EE'	!	E*c                    <"   S! 4       P                  4       p SP                  V P                  4       G R j  xL
 ^4       SP                  V P                  4       G R j  xL
 ^4        V P                  4       P                  \        4       SP                  R4       SP                  V P                  4       G R j  xL
 ^4       SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       R #  L L  \         d.   pSP                  TP                  ^ ,          R4        R p?LR p?ii ; i L LO  + '       g   i     R # ; i5i)Nr   r  )
r   rj   r1   r   r   r   r   r   r   r0   r  r    r  rD   s     r   run2AAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run2  s     "B2<<>1152<<>115:$$%67 		892<<>115""#566lln$$ 76 21 ! 3  T223 2$ 766s   4ED'ED 	E*#D
 /E<E=&E#E	7E8E	<EE
E#D=8E=EEE		E		ENrY  r!   )rD   r  r  r  s   f  @r   test_async_gen_asyncio_anext_043AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04   s<    		
	%	% 			$$TV,		$$TV,r   c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 :   "   ^5x p V 5x p V ^d,          5x  R# 5ir   r
   r   s    r   r  @AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.foo+  s     AAc'Ms   c                  j  <"   S! 4       P                  4       p  V P                  4       P                  R 4       SP                  R4        V P                  4       P                  ^
4       SP                  R4        V P                  4       P                  ^4       SP                  R4       SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       R #   \         d.   pSP                  TP                  ^ ,          ^4        R p?LR p?ii ; i  \         d.   pSP                  TP                  ^ ,          ^
4        R p?LR p?ii ; i  \         d.   pSP                  TP                  ^ ,          R4        R p?LR p?ii ; i L  + '       g   i     R # ; i5i)Nr   i  )	r   r1   r   r   r   rj   r   r   r0   r  s     r   run@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.run0  sJ    "B:##D) 		89:##B' 		89:##B' 		89""#566lln$$ 76' ! 0  Q//0 ! 1  R001 ! 3  T223 % 766s   F3C, F3D' *F3<E" .F3	FFF"
F3,D$7#DF3D$$F3'E2#EF3EF3"F-#FF3FF3FF0	*	F3Nr  rD   r  r  s   f @r   test_async_gen_asyncio_anext_053AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05*  s#    	
	%6 			$$SU+r   c                Z  a aa ^ oR pV! 4       pVP                  R4       S P                  \        4      ;_uu_ 4        VP                  R4       RRR4       V3R loVVV 3R lpS P                  P	                  V! 4       4       S P                  S^4       R#   + '       g   i     LR; i)r   c               3   (   "    R x  R #     R # ; i5ir$   r
   r
   r   r   r  @AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.fooQ          
 Nc                 4   <"    R 5x  ^o R #     ^o R # ; i5ir$   r
   DONEs   r   r)   @AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.gen]  #      DD    c                    <"   S! 4       p V P                  R 4      G R j  xL
  SP                  \        4      ;_uu_ 4        V P                  R 4      G R j  xL
  R R R 4       S^
,          oR #  LN L  + '       g   i     L; i5ir$   )r   r   r0   rc   r  r)   rD   s    r   r  @AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.rune  s_     A''$-""#566ggdm## 7BJD  # 76s9   BA.!BA2A0A2B0A22B	=B)r   r   r   rY  r!   rj   rD   r  rc   r  r  r)   s   f   @@r   test_async_gen_asyncio_anext_063AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06M  s{    	
 E	t}--FF4L .
		 			$$SU+r"- .-s   BB*	c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 H   "    R5x  R#   \          d
    R5x   R# i ; i5i)r   Nr   r  r  r
   r   r   r  CAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.fooq  s"     
$ 
   " """c                  H  <"   S! 4       P                  4       p SP                  V P                  4       G R j  xL
 R4       SP                  \        4      ;_uu_ 4       pV P                  4       P                  \        4       R R R 4       SP                  XP                  P                  ^ ,          R4       SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       R #  L  + '       g   i     L; i L#  + '       g   i     R # ; i5i)Nr  r  )
r   rj   r1   r   r   r   r   	exceptionr   r0   )r  cmr  rD   s     r   r  CAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.runw  s     "B2<<>148""=11R$$%67 2R\\..q148""#566lln$$ 76	 211 % 766sR   4D"C7&D"$C9AD"D(D)D-D"9D		D"DD		D"Nr  r  s   f @r   "test_async_gen_asyncio_anext_tuple6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuplep  s#    		% 			$$SU+r   c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                    "   R# 5i)FNr
   r
   r   r   r  QAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple_no_exceptions.<locals>.foo  s        c                  0  <"   S! 4       P                  4       p SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       \	        V R4      G R j  xL
 pSP                  VR4       R #  L4  + '       g   i     L:; i L-5i)N)rv   b)r   r   r0   r1   r   assertTupleEqual)r  r'   r  rD   s     r   r  QAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple_no_exceptions.<locals>.run  sj     "B""#566lln$$ 7b*--C!!#z2 % 76-s:   3BB
A?BB&B'B?BB		BNr  r  s   f @r   0test_async_gen_asyncio_anext_tuple_no_exceptionsDAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple_no_exceptions  s#    		3 			$$SU+r   c           
       a R p\         \        \        \        3 F  pV! V4      oV P	                  SR7      ;_uu_ 4         ! V3R lR4      pV P                  W!4      ;_uu_ 4        \        V! 4       4       RRR4       V P                  W!4      ;_uu_ 4        \        V! 4       ^4       RRR4       RRR4       K  	  R#   + '       g   i     LQ; i  + '       g   i     L1; i  + '       g   i     K  ; i)custom)r   c                   .   <a  ] tR tRt o V3R ltRtV tR# )?AsyncGenAsyncioTest.test_sync_anext_raises_exception.<locals>.Ai  c                   < Shr$   r
   )rD   r   s   &r   r1   IAsyncGenAsyncioTest.test_sync_anext_raises_exception.<locals>.A.__anext__  s    !	r   r
   N)r   r   r   r   r1   r   rX   )rZ   r   s   @r   Ar    s     " "r   r  N)r0   r   
ValueErrorra   rf  r@   r   )rD   msgexc_typer  r   s   &   @r    test_sync_anext_raises_exception4AsyncGenAsyncioTest.test_sync_anext_raises_exception  s    	
H 3-C#&&" " ++H::!#J ;++H::!#qM ; '&
 ;::: '&&s;   'C&&C 7!C&C*C& CC&C#C&&C7c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 l   "    \        ^4      5x  R#   \         d    \        ^4      5x   R# i ; i5ir   )r   r   r
   r   r   r  KAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.foo  s.     '#A&&$ '#A&&'s   4 41414c                    <"   S! 4       P                  4       p V P                  4       G R j  xL
 pSP                  V\        4       SP	                  VP
                  ^4       SP                  \        4      ;_uu_ 4       pV P                  4       P                  \        4       R R R 4       XP                  P                  ^ ,          pSP                  V\        4       SP	                  VP
                  ^4       SP                  \        4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       R #  EL  + '       g   i     L; i L$  + '       g   i     R # ; i5ir$   )r   r1   r5  r   rj   r1  r   r   r   r  r   r0   )r  r   r  r  rD   s      r   r  KAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.run  s     "Blln$A!!!]3QWWa(""=11R$$%67 2!!!$A!!!]3QWWa(""#566lln$$ 76 % 21 % 766sS   )E'D;AE' $D>$A4E'E,E-E1E'>E		E'EE$		E'Nr  r  s   f @r   *test_async_gen_asyncio_anext_stopiteration>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration  s#    	'	% 			$$SU+r   c                   a R  oV3R lpV P                  \        R4      ;_uu_ 4        V P                  P                  V! 4       4       RRR4       R#   + '       g   i     R# ; i)c                    "    ^5x  ^^ ,           \         P                  R4      G Rj  xL
  ^5x  R#  L  \         P                  R4      G Rj  xL 
  ^5x  i ; i5irn  rp  r
   r   r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.foo  sI     AmmD))) *gmmD)))s.   A 8 A 6A AAAA c                     <"   S! 4       p V P                  4       pVP                  4       G R j  xL
  V P                  4       G R j  xL
  R #  L L5ir$   r   r1   r;  r)   r  r  s     r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.run  >     %CB,,.  **, !!   +AAAAAAz%async generator ignored GeneratorExitN)r@   r   rY  r!   r  s   & @r    test_async_gen_asyncio_aclose_064AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06  sS    		 ##79 9 II((/9 9 9 9s   !AA%	c                   aa ^ oV3R loV3R lpV P                   P                  V! 4       4       V P                  S^4       R# )r   c                 b  <"    ^5x  ^^ ,           \         P                  R4      G Rj  xL
  \         P                  R4      G Rj  xL
  S ^,          o S R,          o R#  L5 L  \         P                  R4      G Rj  xL 
  \         P                  R4      G Rj  xL 
  S ^,          o i ; i5ir  rp  r  s   r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.foo  s     AmmD)))mmD)))	DLD *) mmD)))mmD)))	sO   B/A% B/A!B/A#	B/#B/%B,>B?B,BB,,B/c                     <"   S! 4       p V P                  4       pVP                  4       G R j  xL
  V P                  4       G R j  xL
  R #  L L5ir$   r  r  s     r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.run  r  r  Nr  )rD   r  r  r  s   & @@r    test_async_gen_asyncio_aclose_074AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07  s8    			 			$$SU+q!r   c                N  a aaa ^ o\         P                  S P                  R7      oVV3R loVV 3R lpS P                  P                  V! 4       4       S P	                  S^4       SP                  4        S P                  P                  \         P                  R4      4       R# )r   rY  c                   <"    ^5x  SG Rj  xL
  S R,          o ^5x  \         P                  R4      G Rj  xL
  \         P                  R4      G Rj  xL
  S ^,          o S R,          o R#  L` L7 L  \         P                  R4      G Rj  xL 
  \         P                  R4      G Rj  xL 
  S ^,          o i ; i5i)r   Nr  ro  rp  )r  r   s   r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.foo  s     		mmD)))mmD)))	DLD  *) mmD)))mmD)))	se   C 
A6 A0A6 C A2C A4C 0A6 2C 4C 6B=BB=-B0.B==C c                     <"   S! 4       p V P                  4       pSP                  VP                  4       G R j  xL
 ^4       V P                  4       G R j  xL
  R #  L# L5ir$   )r   rj   r1   r;  )r)   r  r  rD   s     r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.run  sH     %CB2<<>115**, 2s!   6A!AA!AA!A!ro  N)r   FuturerY  r!   rj   cancelrq  )rD   r  r  r  r   s   f @@@r    test_async_gen_asyncio_aclose_084AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08  sr    nn$))n,		 			$$SU+q! 	

		$$W]]4%89r   c                   aa ^ oV3R loV3R lpV P                   P                  V! 4       4       V P                  S^4       R# )r   c                 h   <"     ^5x  K    \         P                  ^ 4      G Rj  xL 
  ^o i ; i5ir   rp  r  s   r   r)   DAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.gen  s+     GmmA&&&s   2 /)/2c                    <"   S! 4       p V P                  4       G R j  xL
  V P                  4       G R j  xL
  ? \        4        \        P                  ^ 4      G R j  xL
  \        P                  ^ 4      G R j  xL
  R #  Lc LM L' L5ir$   )r1   r   r   rq  )rc   r)   s    r   r  DAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.run  si     A++-++-L --"""--"""  
 #"sC   B
BB
B'B
BB
;B<B
B
B
B
Nr  )rD   r  r  r)   s   & @@r   #test_async_gen_asyncio_gc_aclose_097AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09	  s8    	
	# 			$$SU+q!r   c                   aa ^ oR pV! 4       pVP                  R4       VP                  4        V3R loVV3R lpV P                  P                  V! 4       4       V P	                  S^4       R# )r   c               3   (   "    R x  R #     R # ; i5ir$   r
   r
   r   r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.foo(  r  r  Nc                 4   <"    R 5x  ^o R #     ^o R # ; i5ir$   r
   r  s   r   r)   AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.gen3  r  r  c                     <"   S! 4       p V P                  R 4      G R j  xL
  V P                  4       G R j  xL
  S^
,          oR #  L' L5ir$   )r   r;  )rc   r  r)   s    r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.run;  s>     A''$-((*BJD  s   AAAA	A	A)r   r?  rY  r!   rj   r  s   &   @@r    test_async_gen_asyncio_aclose_104AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10$  sZ    	
 E	t				 			$$SU+r"r   c                Z  a aa ^ oR pV! 4       pVP                  R4       S P                  \        R4      ;_uu_ 4        VP                  4        RRR4       V3R loVVV 3R lpS P                  P                  V! 4       4       S P                  S^
4       R#   + '       g   i     LR; i)r   c               3   .   "    R x  R x  R #     L
; i5ir$   r
   r
   r   r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.fooI  s      s    Nignored GeneratorExitc                 F   <"    R 5x  R 5x  S ^,          o R #     L; i5ir$   r
   r  s   r   r)   AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.genV  s%      AIDs   ! !!c                    <"   S! 4       p V P                  R 4      G R j  xL
  SP                  \        R4      ;_uu_ 4        V P                  4       G R j  xL
  R R R 4       S^
,          oR #  LN L  + '       g   i     L; i5i)Nr  )r   r@   r   r;  r  s    r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.run_  sa     A''$-''6MNNhhj   OBJD    ONs9   BA."BA2A0A2B0A22B	=B)r   r@   r   r?  rY  r!   rj   r  s   f   @@r    test_async_gen_asyncio_aclose_114AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11E  s~    	 E	t##L2IJJGGI K
		 			$$SU+r"/ KJs   BB*	c                   aaa ^ oR oVV3R loV3R lpV P                   P                  V! 4       4       V P                  S^4       R# )r   c                  ^   "   \         P                  R 4      G Rj  xL
  ^^ ,           R#  L5iro  Nrp  r
   r   r   targetDAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.targetm  s%     --%%%EE &   -+-c                    <"   \         P                  S! 4       4      p  ^5x   V G Rj  xL
  R#  L  \         d    ^o R# i ; i   T G Rj  xL 
  i   \         d    ^o i i ; i; i5ir   )r   create_taskr   )taskr  r  s    r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.fooq  sa     &&vx0DJJ( DJJ( Dsr   A+A 3 13 A+3 A A+AA+A(	AAAA(A%"A($A%%A((A+c                     <"   S! 4       p V P                  4       pVP                  4       G R j  xL
  V P                  4       G R j  xL
  R #  L L5ir$   r  r  s     r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.run|  r  r  Nr  )rD   r  r  r  r  s   & @@@r    test_async_gen_asyncio_aclose_124AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12j  s=    				 			$$SU+q!r   c                .  a aa ^ oR pV! 4       pVP                  R4      pS P                  V^4       VP                  ^d4      pS P                  V^4       V3R loVV 3R lpS P                  P                  V! 4       4       S P                  S^4       R# )r   c               3   ,   "   ^x p V ^,          x  R# 5ir   r
   r   s    r   sgenAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.sgen  s     Aa%Ks   Nc                   <"    \         P                  R 4      G Rj  xL
  ^5x p \         P                  R 4      G Rj  xL
  V ^,          5x  \         P                  R 4      G Rj  xL
   \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  ^oR#  L Ln LG L+ L  \         P                  R 4      G Rj  xL 
  \         P                  R 4      G Rj  xL 
  ^oi ; i5ir  rp  )r   r  s    r   r)   @AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.gen  s     
mmD)))GmmD)))!emmD)))mmD)))mmD))) *)) *) mmD)))mmD)))s   C9B6 B,!B6 B. (B6 (B0)B6 .C9B2C9#B4$C9,B6 .B6 0B6 2C94C96C6CC6-C0.C66C9c                  |  <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4       V P                  ^d4      G R j  xL
 pSP                  V^4       SP                  \        4      ;_uu_ 4        V P                  R 4      G R j  xL
  R R R 4       R #  L LY L  + '       g   i     R # ; i5ir$   )r   rj   r   r0   rc   r   r)   rD   s     r   r  @AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.run  s     Aggdm#AQ"ggcl"AQ$""#566ggdm## 76 $ # $ 766K   B<B"*B<
B$3B<>B(B&B(B<$B<&B((B9	3	B<)r   rj   rY  r!   )rD   r  r   r   r  r  r)   s   f    @@r   test_async_gen_asyncio_asend_013AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01  s    	 VGGDMAGGCLC 	
	$ 			$$SU+q!r   c                
  a aaa ^ oR oVV3R loVV 3R lpS P                  \        4      ;_uu_ 4        S P                  P                  V! 4       4       RRR4       S P	                  S^4       R#   + '       g   i     L$; i)r   c                 ^   "   \         P                  V 4      G R j  xL
  ^^ ,           R #  L5ir$   rp  )delays   &r   sleep_n_crashJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.sleep_n_crash  s%     --&&&EE 'r  c                   <"    \         P                  R 4      G Rj  xL
  ^5x p S! R 4      G Rj  xL
  SR,          oV ^,          5x  \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  ^oR#  Ll LY L) L  \         P                  R 4      G Rj  xL 
  \         P                  R 4      G Rj  xL 
  ^oi ; i5iro  Nr  rp  r   r  r(  s    r   r)   @AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.gen       	mmD)))G#D)))!emmD)))mmD))) *) *) mmD)))mmD)))x   CB B
B BB C$B%CBC
B B CCC+B.,C	C
CCc                     <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4       V P                  ^d4      G R j  xL
  R #  L1 L5ir$   r   rj   r   s     r   r  @AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.run  H     Aggdm#AQ"''#, $ !   AA*A
AAAN)r   r   rY  r!   rj   rD   r  r  r)   r(  s   f @@@r   test_async_gen_asyncio_asend_023AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02  s]    			 011II((/ 2q! 21s   !A22B	c                $  a aaa ^ oV 3R loVV3R loVV 3R lpS P                  \        P                  4      ;_uu_ 4        S P                  P	                  V! 4       4       RRR4       S P                  S^4       R#   + '       g   i     L$; i)r   c                    <a"   \         P                  \         P                  V 4      SP                  R 7      oSP                  P	                  V ^,          V3R l4       SG Rj  xL
 #  L5i)r  c                  $   < S P                  4       # r$   r  r   s   r   <lambda>\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash.<locals>.<lambda>      CJJLr   Nr   ensure_futurerq  rY  
call_laterr'  r   rD   s   &@r   r(  JAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash  P     ''e(<-1YY ( 8CII  ,@A99   A!A,%A*&A,c                   <"    \         P                  R 4      G Rj  xL
  ^5x p S! R 4      G Rj  xL
  SR,          oV ^,          5x  \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  ^oR#  Ll LY L) L  \         P                  R 4      G Rj  xL 
  \         P                  R 4      G Rj  xL 
  ^oi ; i5ir+  rp  r,  s    r   r)   @AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.gen  r.  r/  c                     <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4       V P                  ^d4      G R j  xL
  R #  L1 L5ir$   r1  r   s     r   r  @AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.run  r3  r4  N)r   r   CancelledErrorrY  r!   rj   r5  s   f @@@r   test_async_gen_asyncio_asend_033AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03  sb    			 w5566II((/ 7q! 76s   !A??B	c                  a aaa ^ o ! R R\         4      oV3R lpV! 4       pVP                  R4      pS P                  V^4       VP                  S4      pS P                  VR4       S P	                  \
        4      ;_uu_ 4        VP                  R4       RRR4       VV3R loVVV 3R lpS P                  P                  V! 4       4       S P                  S^4       R#   + '       g   i     LS; i)r   c                       ] tR tRtRtR# )CAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.FooEri  r
   Nr   r
   r   r   FooErrP    r   r   rQ  c               3   N   <"    ^x p V ^,          x  R#   S d    Rp  Li ; i5i)r   r  Nr
   )r   rQ  s    r   r  BAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.sgen  s2     G a%K  s   % %	"%"%N  c                   <"    \         P                  R 4      G Rj  xL
   ^5x p V ^,          5x  \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  ^oR#  Lq  S d$    Rp \         P                  R 4      G Rj  xL 
   Li ; i Lq LV L;  \         P                  R 4      G Rj  xL 
  \         P                  R 4      G Rj  xL 
  ^oi ; i5ir+  rp  )r   r  rQ  s    r   r)   AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.gen  s     mmD))).A !emmD))) mmD)))mmD))) *  .A!-----. * *) mmD)))mmD)))s   DC BC B $C B>C D)C *DCDC !B;2B53B;8C :B;;C  DDDC D;C><DDc                  |  <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4       V P                  S4      G R j  xL
 pSP                  VR4       SP                  \        4      ;_uu_ 4        V P                  R 4      G R j  xL
  R R R 4       R #  L LY L  + '       g   i     R # ; i5i)NrT  )r   rj   r   r   r0   )rc   r   rQ  r)   rD   s     r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.run  s     Aggdm#AQ"hhuo%AQ%""#566ggdm## 76 $ & $ 766r"  )ra   r   rj   r   r   r   rY  r!   )rD   r  r   r   r  r  rQ  r)   s   f    @@@r    test_async_gen_asyncio_athrow_014AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01  s    	I 		 VGGDMAHHUOD!}--GGDM .	"
	$ 			$$SU+q!C .-s   C##C3	c                J  a aaaa ^ o ! R R\         4      oV 3R loVVV3R loVVVV 3R lpS P                  \        P                  4      ;_uu_ 4        S P                  P                  V! 4       4       RRR4       S P                  S^4       R#   + '       g   i     L$; i)r   c                       ] tR tRtRtR# )CAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.FooEri)  r
   Nr   r
   r   r   rQ  r]  )  r   r   rQ  c                    <a"   \         P                  \         P                  V 4      SP                  R 7      oSP                  P	                  V ^,          V3R l4       SG Rj  xL
 #  L5i)r  c                  $   < S P                  4       # r$   r;  r<  s   r   r=  ]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash.<locals>.<lambda>/  r?  r   Nr@  rC  s   &@r   r(  KAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash,  rE  rF  c                   <"    \         P                  R 4      G Rj  xL
   ^5x p X ^,          5x  \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  \         P                  R 4      G Rj  xL
  ^oR#  Lq  S d    S! R 4      G Rj  xL 
   Li ; i Lb LG L,  \         P                  R 4      G Rj  xL 
  \         P                  R 4      G Rj  xL 
  ^oi ; i5ir  rp  )r   r  rQ  r(  s    r   r)   AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.gen2  s     mmD))).A !emmD))) mmD)))mmD))) *  .'---. * *) mmD)))mmD)))s   C8B5 BB5 B $B5 B/B5 C8)B1*C8B3C8B5 B,#B&$B,)B5 +B,,B5 1C83C85C5CC5,C/-C55C8c                  *  <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4        V P                  S4      G R j  xL
  SP                  R4       R #  LC L  \        P
                   d    SP                  S^4       h i ; i5i)NzCancelledError was not raised)r   rj   r   r   r   rK  )rc   r   r  rQ  r)   rD   s     r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.runB  s     Aggdm#AQ";hhuo%%
 		9: $ &))   q)s8   BA#BA' A%A' B%A' ')BBN)ra   r   r   rK  rY  r!   rj   )rD   r  r  rQ  r)   r(  s   f @@@@r    test_async_gen_asyncio_athrow_024AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02&  ss    	I 			 	; 	; w5566II((/ 7q! 76s   !BB"	c                b  a aa ^ oR pV! 4       pVP                  R4       S P                  \        4      ;_uu_ 4        VP                  \        4       RRR4       V3R loVVV 3R lpS P
                  P                  V! 4       4       S P                  S^4       R#   + '       g   i     LR; i)r   c               3   (   "    R x  R #     R # ; i5ir$   r
   r
   r   r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.fooX  r  r  Nc                 4   <"    R 5x  ^o R #     ^o R # ; i5ir$   r
   r  s   r   r)   AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.gend  r  r  c                    <"   S! 4       p V P                  R 4      G R j  xL
  SP                  \        4      ;_uu_ 4        V P                  \        4      G R j  xL
  R R R 4       S^
,          oR #  LR L  + '       g   i     L; i5ir$   )r   r   r0   r   r  r  s    r   r  AAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.runl  s`     A''$-""#566hhz*** 7BJD  * 76s9   B	A2!B	A6A4A6B	4A66B	B	)r   r   r   r   r  rY  r!   rj   r  s   f   @@r    test_async_gen_asyncio_athrow_034AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03T  s|    	
 E	t}--GGJ .
		 			$$SU+r"- .-s   BB.	c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 H   "    ^5x  R#   \          d
    R5x   R# i ; i5i)r   Nr  r  r
   r   r   r)   DAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.genx  s"     $ 
r  c                    <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4       V P                  \        4      G R j  xL
 pSP                  VR4       SP	                  \
        4      ;_uu_ 4        V P                  R 4      G R j  xL
  R R R 4       R #  L LY L  + '       g   i     R # ; i5i)Nr  )r   rj   r   r   r   r0   r   s     r   r  DAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.run~  s     Aggdm#AQ"hh011AQ%""#566ggdm## 76	 $1 $ 766sK   C B&.C B(3C B,B*B,C (C *B,,B=	7	C Nr  rD   r  r)   s   f @r   #test_async_gen_asyncio_athrow_tuple7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuplew  s#    		$ 			$$SU+r   c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 Z   "    ^5x  R#   \          d    \        ^4      5x   R# i ; i5ir   )r   r   r
   r   r   r)   LAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.gen  s(     '$ '#A&&'s   + +(+(+c                    <"   S! 4       p V P                  R 4      G R j  xL
 pSP                  V^4       V P                  \        4      G R j  xL
 pSP	                  V\
        4       SP                  VP                  ^4       SP                  \        4      ;_uu_ 4        V P                  R 4      G R j  xL
  R R R 4       R #  L Ly L  + '       g   i     R # ; i5ir$   )	r   rj   r   r   r5  r   r1  r   r0   r   s     r   r  LAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.run  s     Aggdm#AQ"hh011A!!!]3QWWa(""#566ggdm## 76 $1 $ 766sL   C C.C CAC "C7C
8C<C C 
CC		C Nr  rv  s   f @r   +test_async_gen_asyncio_athrow_stopiteration?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration  s#    	'	$ 			$$SU+r   c                D  aa ^ oV3R loV3R lpV P                   P                  V! 4       4      pV P                   P                  V! 4       4      pV P                   P                  \        P	                  R4      4       VP                  4        VP                  4        V P                  \        P                  4      ;_uu_ 4        V P                   P                  V4       RRR4       V P                  \        P                  4      ;_uu_ 4        V P                   P                  V4       RRR4       V P                   P                  V P                   P                  4       4       V P                  S^4       R#   + '       g   i     L; i  + '       g   i     Lj; i)r   c                  <"    \         P                  V 4      G R j  xL
  ^5x  \         P                  ^ 4      G R j  xL
  S^,          oR #  L1 L  \         P                  ^ 4      G R j  xL 
  S^,          oi ; i5ir$   rp  )timeout	finalizeds   &r   waiterFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waiter  sb     mmG,,,mmA&&&Q		 - 'gmmA&&&Q	sH   A?A A	A A?A A?A A?A<,A/-A<<A?c                  >   <"   S! ^4        Rj  xL
  p K   LDR# 5ir   r
   )_r  s    r   waitDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.wait  s#     !!9  a9s   	g?N)
rY  r  r!   r   rq  r  r   rK  shutdown_asyncgensrj   )rD   r  t1t2r  r  s   &   @@r   "test_async_gen_asyncio_shutdown_016AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01  s   			 YY""46*YY""46*		$$W]]3%78 			
		w5566II((, 7w5566II((, 7 			$$TYY%A%A%CDA& 7666s   E<F<F	F	c                   aaa . oV3R  loR pV! 4       oVV3R lp\         P                  V! 4       4       V P                  S. 4       R# )c                 *   < SP                  V4       R # r$   r%   rY  contextmessagess   &&r   exception_handlerQAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.exception_handler      OOG$r   c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   MAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.async_iterate  r  r   c                  ~   <"   \         P                  4       p V P                  S4       S  R j  xL
  p R #  LD	R # 5ir$   r   get_running_loopset_exception_handlerrY  r(   r  r  s     r   mainDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.main  <     ++-D&&'89  a2   (=:8:=:=N)r   r  rj   )rD   rh   r  r  r  r  s   &  @@@r   "test_async_gen_asyncio_shutdown_026AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02  s@    	%	 _	 	DF2&r   c                  aaa . oV3R  loR pV! 4       oVV3R lp\         P                  V! 4       4       Sw  pV P                  VR,          S4       V P                  VR,          \        4       V P                  RVR,          4       R# )c                 *   < SP                  V4       R # r$   r%   r  s   &&r   r  [AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.exception_handler  r  r   c                 R   "    ^5x  ^5x  ^^ ,           R#   ^^ ,           i ; i5ir   r
   r
   r   r   rh   WAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.async_iterate  $     !!   '
 '$'c                  ~   <"   \         P                  4       p V P                  S4       S  R j  xL
  p R #  LD	R # 5ir$   r  r  s     r   r  NAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.main  r  r  asyncgenr  z:an error occurred during closing of asynchronous generatormessageN)r   r  rj   r5  r   r2  )rD   rh   r  r  r  r  r  s   &   @@@r   ,test_async_gen_asyncio_shutdown_exception_01@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01  sy    	%	 _	 	DF,b1gk24EFRi(	*r   c                   aaa . oV3R  loR oVV3R lp\         P                  V! 4       4       Sw  pV P                  VR,          \        4       V P	                  RVR,          4       ?>\        4        R# )c                 *   < SP                  V4       R # r$   r%   r  s   &&r   r  [AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.exception_handler  r  r   c                 R   "    ^5x  ^5x  ^^ ,           R#   ^^ ,           i ; i5ir   r
   r
   r   r   rh   WAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.async_iterate  r  r  c                     <"   \         P                  4       p V P                  S4       S! 4         R j  xL
  p \        4        R #  LDL5ir$   )r   r  r  r   rY  r(   rh   r  s     r   r  NAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.main  sC     ++-D&&'89(?  aL?s%   -AA	AA	AA		Ar  z1unhandled exception during asyncio.run() shutdownr  N)r   r  r5  r   r2  r   )rD   r  r  rh   r  r  s   &  @@@r   ,test_async_gen_asyncio_shutdown_exception_02@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02  se    	%		 	DFgk24EFIi(	*Xr   c                   aa R  oV3R loV3R lpV P                   P                  V! 4       4      pT P                  T\        ^
4       Uu. uF  q3^,          NK  	  up4       R# u upi )c                z   "   \        V 4       F%  p\        P                  R 4      G Rj  xL
  V5x  K'  	  R#  L5ir  )ranger   rq  )nr(   s   & r   arange@AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.arange  s-     1XmmD))) )s   ';9;c                 "   < R  S! V 4       4       # )c                B   "   T  R j  xL
 q^,          5x  K   LDR # 5ir$   r
   ).0r(   s   & r   	<genexpr>XAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange.<locals>.<genexpr>  s     33AEE3s   r
   )r  r  s   &r   make_arangeEAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange  s    333r   c                  R   <"   S! ^
4       U u. u Rj  xL
 q NK   LDup # u up i 5ir   r
   r(   r  s    r   r  =AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.run  !     %0_55A555$   '"
""'NrY  r!   rj   r  )rD   r  r'   r(   r  r  s   &   @@r   test_async_gen_expression_010AsyncGenAsyncioTest.test_async_gen_expression_01  sT    	
	4	6 ii**351eBi8i1uui898s   A%
c                   aa R  oV3R loV3R lpV P                   P                  V! 4       4      pT P                  T\        ^^
4       Uu. uF  q3^,          NK  	  up4       R# u upi )c                 L   "   \         P                  R 4      G Rj  xL
  V #  L5ir  rp  )r  s   &r   wrap>AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.wrap   s!     --%%%H &s   $"$c                 .   < V3R  l\        V 4       4       # )c                l   <"   T F'  pS! V4      G R j  xL
 '       g   K  V^,          5x  K)  	  R #  L5ir$   r
   )r  r(   r  s   & r   r  XAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange.<locals>.<genexpr>&  s%     =8aT!W}}EAEE8}s   4244)r  )r  r  s   &r   r  EAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange$  s    =58==r   c                  R   <"   S! ^
4       U u. u Rj  xL
 q NK   LDup # u up i 5ir   r
   r  s    r   r  =AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.run(  r  r  Nr  )rD   r  r'   r(   r  r  s   &   @@r   test_async_gen_expression_020AsyncGenAsyncioTest.test_async_gen_expression_02  sV    		>	6 ii**351eArl;l1uul;<;s   A&
c                   R  pR pRpV P                   P                  V! V! 4       4      4       V P                  \        V4      ;_uu_ 4        V P                   P                  V! R4      4       RRR4       R#   + '       g   i     R# ; i)c                    "   ^*5x  R# 5i)r  Nr
   r
   r   r   agCAsyncGenAsyncioTest.test_async_gen_expression_incorrect.<locals>.ag/  s
     Hr   c                     "   R  V  4        R# 5i)c                4   "   T  R j  xL
 q5x  K   L
DR # 5ir$   r
   )r  r+  s   & r   r  WAsyncGenAsyncioTest.test_async_gen_expression_incorrect.<locals>.run.<locals>.<genexpr>3  s     ""Q"s   Nr
   )args   &r   r  DAsyncGenAsyncioTest.test_async_gen_expression_incorrect.<locals>.run2  s     "c"r   z<'async for' requires an object with __aiter__ method, got .*N)rY  r!   r@   r8   )rD   r  r  err_msg_asyncs   &   r   #test_async_gen_expression_incorrect7AsyncGenAsyncioTest.test_async_gen_expression_incorrect.  se    		#' 			$$SY/##I}==II((T3 >===s   "A99B
	c                   aaa . oV3R  loR oVV3R lp\         P                  V! 4       4       V P                  . S4       \        4        R# )c                 *   < SP                  V4       R # r$   r%   r  s   &&r   r  ]AsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.exception_handler@  r  r   c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   YAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.async_iterateC  r  r   c                     <"   \         P                  4       p V P                  S4       S! 4         R j  xL
  p R #  LD	R # 5ir$   r  r  s     r   r  PAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.mainG  s>     ++-D&&'89(?  a?s   -A?=?A?AN)r   r  rj   r   )rD   r  rh   r  r  s   & @@@r   .test_asyncgen_nonstarted_hooks_are_cancellableBAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable<  s<    	%		 	DFX&r   c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   UAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.async_iterateT  r  r   c                    <"   S! 4       p V P                  4       pVG R j  xL
  SP                  \        R4      ;_uu_ 4        VG R j  xL
  R R R 4       V P                  4       G R j  xL
  R #  LO L(  + '       g   i     L.; i L5i)Nr   )r1   r@   r   r;  r  nxtrh   rD   s     r   r  KAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.runX  sq     B,,.CII'' K  			 ))+ 
 	  sE   B	A0"B	A4	A2
A4B	)B*B	2A44B	?	B	Nr  rD   r  rh   s   f @r   *test_async_gen_await_same_anext_coro_twice>AsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twiceS  s#    	
	 			$$SU+r   c                ^   a a R  oVV 3R lpS P                   P                  V! 4       4       R# )c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   VAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.async_iterateg  r  r   c                     <"   S! 4       p V P                  4       pVG R j  xL
  SP                  \        R4      ;_uu_ 4        VG R j  xL
  R R R 4       R #  L7 L  + '       g   i     R # ; i5i)Nr  )r;  r@   r   r  s     r   r  LAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.runk  sd     B))+CII'' I  			  
 	  s9   A0A"A0A	A
AA0AA-	'	A0Nr  r  s   f @r   +test_async_gen_await_same_aclose_coro_twice?AsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twicef  s#    		 			$$SU+r   c                v   R  pV! 4       pVP                  4       pV P                  \        4      ;_uu_ 4        VP                  \        4       RRR4       V P                  \        R4      ;_uu_ 4        VP                  \        4       RRR4       R#   + '       g   i     LN; i  + '       g   i     R# ; i)c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   VAsyncGenAsyncioTest.test_async_gen_throw_same_aclose_coro_twice.<locals>.async_iteratex  r  r   Nr  )r;  r   r   r   r   r@   r   )rD   rh   r  r  s   &   r   +test_async_gen_throw_same_aclose_coro_twice?AsyncGenAsyncioTest.test_async_gen_throw_same_aclose_coro_twicew  s    	 _iik}--IIm$ . ##A
 
 IIm$	
 
 .-
 
 
s   B4B'B$	'B8	c                |   R  pV! 4       p ! R R\         4      pVP                  4       pV P                  V4      ;_uu_ 4        VP                  V4       RRR4       V P	                  \
        R4      ;_uu_ 4        VP                  V4       RRR4       R#   + '       g   i     LJ; i  + '       g   i     R# ; i)c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   ]AsyncGenAsyncioTest.test_async_gen_throw_custom_same_aclose_coro_twice.<locals>.async_iterate  r  r   c                       ] tR tRtRtR# )[AsyncGenAsyncioTest.test_async_gen_throw_custom_same_aclose_coro_twice.<locals>.MyExceptioni  r
   Nr   r
   r   r   MyExceptionr    r   r   r  Nr  )ra   r;  r   r   r@   r   rD   rh   r  r  r  s   &    r   2test_async_gen_throw_custom_same_aclose_coro_twiceFAsyncGenAsyncioTest.test_async_gen_throw_custom_same_aclose_coro_twice  s    	 _	) 	 iik{++IIk" , ##A
 
 IIk"	
 
 ,+
 
 
s   B;B*B'	*B;	c                ~   R  pV! 4       p ! R R\         4      pVP                  V4      pV P                  V4      ;_uu_ 4        VP                  V4       RRR4       V P	                  \
        R4      ;_uu_ 4        VP                  V4       RRR4       R#   + '       g   i     LJ; i  + '       g   i     R# ; i)c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   ]AsyncGenAsyncioTest.test_async_gen_throw_custom_same_athrow_coro_twice.<locals>.async_iterate  r  r   c                       ] tR tRtRtR# )[AsyncGenAsyncioTest.test_async_gen_throw_custom_same_athrow_coro_twice.<locals>.MyExceptioni  r
   Nr   r
   r   r   r  r    r   r   r  Nr  )ra   r   r   r   r@   r   r  s   &    r   2test_async_gen_throw_custom_same_athrow_coro_twiceFAsyncGenAsyncioTest.test_async_gen_throw_custom_same_athrow_coro_twice  s    	 _	) 	 ii${++IIk" , ##A
 
 IIk"	
 
 ,+
 
 
s   B<B+B(	+B<	c                Z   a R  oV3R lpV P                   P                  V! 4       4       R# )c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   [AsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.async_iterate  r  r   c                     <"   S! 4       p V P                  4       G R j  xL
  V P                  4       G R j  xL
  R #  L L5ir$   r;  )r  rh   s    r   r  QAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.run  s3     B))+))+ s   A=A?AANr  r  s   & @r   0test_async_gen_aclose_twice_with_different_corosDAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros  s#    		
 			$$SU+r   c                Z   a R  oV3R lpV P                   P                  V! 4       4       R# )c                 "   "   ^5x  ^5x  R# 5ir   r
   r
   r   r   rh   QAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.async_iterate  r  r   c                  r   <"   S! 4       p V   R j  xL
  pK   LDT P                  4       G R j  xL 
  R # 5ir$   r  )r  r  rh   s     r   r  GAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.run  s5     B  a2))+s$   
77727Nr  r  s   & @r   &test_async_gen_aclose_after_exhaustion:AsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion  s#    		 			$$SU+r   c                Z   a R  oV3R lpV P                   P                  V! 4       4       R# )c                 (   "   \        4       5x  R # 5ir$   )objectr
   r   r   async_generator\AsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.async_generator  s     (Ns   c                     <"   S! 4       p \         P                  V P                  4       4       \         P                  4       pV F  pVP	                  4        K  	  R # 5ir$   )r   r  r;  	all_tasks	get_stack)r  tasksr  r)  s      r   r  PAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.run  sD      "B		,%%'E  s   AANr  )rD   r  r)  s   & @r   /test_async_gen_aclose_compatible_with_get_stackCAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack  s#    		! 			$$SU+r   r  N)Br   r   r   r   r\  ra  ri  rg  r  r  r  r  r  r  r  r  r  r  r  r$  r\  rh  r,   rt  ry  r  r  r  r  r  r  r  r  r  r  r  r  r  r	  r  r#  r6  rL  rY  rf  ro  rw  r~  r  r  r  r  r  r  r  r  r  r   r  r  r  r  r$  r0  r   rX   rY   s   @r   rV  rV  o  sG    %4
?1.f.5B&&*"3<(.*...*obE 
&	>
&(-T!,F!#F,&,""(,.0(".:>"6#B##J"6("T"@ "D3"j,"\!#F,$,& 'D',*:<: =4.,&,"% #(#(,,, ,r   rV  c                   D   a  ] tR tRt o R tR tR tR tR tR t	Rt
V tR	# )
TestUnawaitedWarningsi  c                X   R  p V! 4       pVP                  R4      P                  R4       RVP                   R2pV P	                  \
        V4      ;_uu_ 4        V! 4       pVP                  R4       \        4        RRR4       R#   \         d     Lhi ; i  + '       g   i     R# ; i)c                    "   ^5x  R# 5ir   r
   r
   r   r   r)   -TestUnawaitedWarnings.test_asend.<locals>.gen  r  r   Nr   r   )r   r   r   r   r   r   r   )rD   r)   rc   r  s   &   r   
test_asend TestUnawaitedWarnings.test_asend  s    	
	AGGDMt$ .c.>.>-??RS"">377AGGDML 87	  		 877s   'B #BBBB)	c                    R  pRVP                    R2pV P                  \        V4      ;_uu_ 4        V! 4       pVP                  \        4       \        4        RRR4       R#   + '       g   i     R# ; i)c                    "   ^5x  R# 5ir   r
   r
   r   r   r)   .TestUnawaitedWarnings.test_athrow.<locals>.gen  r  r   zcoroutine method 'athrow' of 'r   N)r   r   r   r   r   r   rD   r)   r  rc   s   &   r   test_athrow!TestUnawaitedWarnings.test_athrow  sY    	 /s/?/?.@@ST"">377AHH\"L 8777s   'A##A4	c                    R  pRVP                    R2pV P                  \        V4      ;_uu_ 4        V! 4       pVP                  4        \	        4        RRR4       R#   + '       g   i     R# ; i)c                    "   ^5x  R# 5ir   r
   r
   r   r   r)   .TestUnawaitedWarnings.test_aclose.<locals>.gen  r  r   zcoroutine method 'aclose' of 'r   N)r   r   r   r;  r   r<  s   &   r   test_aclose!TestUnawaitedWarnings.test_aclose  sV    	 /s/?/?.@@ST"">377AHHJL 8777s   "AA/	c                    R  p ! R R\         4      pV! 4       pV P                  V4      ;_uu_ 4        VP                  4       P                  V4       RRR4       ?\	        4        R#   + '       g   i     L; i)c                    "   R # 5ir$   r
   r
   r   r   r)   4TestUnawaitedWarnings.test_aclose_throw.<locals>.gen  s     r  c                       ] tR tRtRtR# )<TestUnawaitedWarnings.test_aclose_throw.<locals>.MyExceptioni  r
   Nr   r
   r   r   r  rH    r   r   r  N)ra   r   r;  r   r   )rD   r)   r  rc   s   &   r   test_aclose_throw'TestUnawaitedWarnings.test_aclose_throw   sY    		) 	 E{++HHJ[) , 	 ,+s    A((A8	c                `  a \         P                  R  4       oV3R lpV! 4       pVP                  R4      pVP                  R4       VP                  R4      pV P	                  \
        R4      ;_uu_ 4        VP                  R4       RRR4       ?\        4        R#   + '       g   i     L; i)c              3      "   V x # 5ir$   r
   r   s   &r   r   KTestUnawaitedWarnings.test_asend_send_already_running.<locals>._async_yield  r   r   c                 6   <"    S ! ^4      G Rj  xL
  K   L5ir   r
   rG  s   r   r   ETestUnawaitedWarnings.test_asend_send_already_running.<locals>.agenfn       "1o%%   Nr   )r   r   r   r   r@   r   r   rD   r   r   r)   r  r   s   &    @r   test_asend_send_already_running5TestUnawaitedWarnings.test_asend_send_already_running  s    		 
		 xjjzz$##LGI IIIdOI I Is   6BB-	c                h  a \         P                  R  4       oV3R lpV! 4       pVP                  R4      pVP                  R4       VP	                  \
        4      pV P                  \        R4      ;_uu_ 4        VP                  R4       RRR4       ?\        4        R#   + '       g   i     L; i)c              3      "   V x # 5ir$   r
   r   s   &r   r   LTestUnawaitedWarnings.test_athrow_send_already_running.<locals>._async_yield(  r   r   c                 6   <"    S ! ^4      G Rj  xL
  K   L5ir   r
   rG  s   r   r   FTestUnawaitedWarnings.test_athrow_send_already_running.<locals>.agenfn,  rP  rQ  Nr  )	r   r   r   r   r   ra   r@   r   r   rR  s   &    @r    test_athrow_send_already_running6TestUnawaitedWarnings.test_athrow_send_already_running'  s    		 
		 xjj{{9%##LHJ JIIdOJ J Js   :B!!B1	r
   N)r   r   r   r   r7  r=  rB  rI  rS  rZ  r   rX   rY   s   @r   r3  r3    s(     $0 r   r3  __main__)r=  r   unittestry  test.support.import_helperr   test.supportr   r   r   r(  r9   ra   r	   r   r   r!   r,   r:   TestCaser<   r\   rV  r3  r   r  r
   r   r   <module>ra     s        4 <
	
" t $h	Y 	 u   )  + >.** .bf8$$ fRg,(++ g,T+cH-- cJ zMMO r   