ÿØÿà JFIF 

  
 
  ÿÛ „ 
 !.%+&8&+/1555$;@;4?.451
4,$,44444444444414444444444444444444444444444444444444ÿÀ  á á
" 

ÿÄ   



           
 ÿÄ ? 
    
 !1AQaq"2‘¡±ÁðBRbrÑá#‚’¢²3S CñÿÄ 
 

             
ÿÄ ! 
 
 
       
!1QAa‘2ÿÚ 
  ? 5˜Z¯V¦cø)›t/? z¨±>Õ5€¶‹Á¤·¼z¼Ü¬+ñ®v¤¨_ˆR­BFn©—˜ý®ç̝P8gýt·ÉSTŦˆìät?þé¼íìN/Þa)ì–í6ô…
Ï¿øÃj´¿KÇü]ÿ ªô¹-eKànëÕHTx}ýSÜ›ÿ ”7Ø×&µ<¦  ¥ÑO¶[Ù¯ä¨ÞÃÿ PZ-¬;#õ|•
oaÿ ©CìÞz3˜öː/¤­ñTûIØ}š^   mÓ%ªxˆ¥ÉŸu=Z+ISe¿45™¼u;ú&WØ÷€æßQ™®{|
íx*TC“#ZŠìZ§²‹ 6pv…³¿¡äª*áZÐ%ÒOáˆo"x«OHk
w±æ+¬V(kMúŸ5Vö«$ ÁrÏbàb57/luR ¸ÑÛj Òµì`Ðœq­û žICÀ
Ê•©4€Âcà¨Ï€O´<èÐ:›ù(Ë^L8þ‘ÍÌ#¸Ð_Ì©ÙK(Öz 4¬û+¸;ü’V’84‘¬ÃŽ:[â‡ÔÌáõp¢~§ªlæ£ö{®G>J¼"°‡7¯ÆÉèßû ‹É‹§ÁòÃýâßî
^ƾÙõ‹×óH#«LP½ïX=xÑÍ$|W?•~•îëÔ©ª‹
{ÝT…Kÿ ”hûâá)J*ö˜–ÔU;iÇ€/ ÆþjóZ\ýwØ=Ìm
ºèËL9 ýè
Æð/¨’¥öo=nË.%Îì   ŽÕ¯È|{Oj²ƒE6e/ßdÄõ²Ìâ1O®ò×TsəԸhOMýíMˆ¿¼H˜l²,7Â¥#MF/Úf°Ö½± ¸–dr‹NýÊ íjqx{œÉ ä-È    ¦
øÄër¨q°ð
†nцýÑÄÆ’mä…n<0È™;ÁÝá¯ÁZƒ7FÀmì­ É&9ˆîéi¶ùN§Y•ÃZãAâ?•‡©‰ , ó¾IŸŠc1 4â&y­&pŠ­6;M À 0¹qç»p.á …ŸÅáK@<u %Ü6ÓtIÌpÓr»söfeÁ0O…­´Kƒ&ñ™\©<+,~)‹
ºHÐ*×µ&†ž‘Æ÷ÚŸ
1ßjC5Oh´‡›

Ø×ë æâ“Þà

ÒT]§n{ºöB³ ¦ ̹Â8Êï¦MÉ<„¨s¹¶ì7Ì”æR$Ncà! /éþäRM÷Gƒ¿É$
¦oà>%6·y6ƒ‰3?”úºŽ‰éX5ªPT §µ!=Mž«Ú½‹ÅgÂSâÉaþÓoö–¯ÁÔìR>5éÿ üs¶ÆUcÌ  kÇR
]ÿ ù¬¼«VŽ;Â|‡~¢¦”ÏÅ°æ
{L™Õ°Óv¹ò¸írŽ¡×¢CÃ!íVÕ {¶»sŒNPg/
"uÕbkm²“$ďå¿é¹§°½æz¯6 †s¿!s–wÚÝ“™Œ°.ûj>·+™Òa…©Œ&rÝÎtÛë긪Ît’LAVp%c Úý[ÄzJ¾ÇàXXç@˜ó<êL]·T˜¾¥1Ó©V‡g´æ½¦Ý@¹óø!_@´ÞâSÁ —S3™•& ]@JHÚý©ZŽ €×æÔr»Áf!‡yÞ4Mv*èÓã_{‘åóUuљØ«Oïé*®EvÑ
Œ÷‡U \"㪒ÍK+À 4“M¡ï:0¥5í!'<@î´”>Ç»&Z–ïCCV˜Ì5Šo&îhè.žû
|ÓK©h$s6KìŒëã)¹hI¦GïOåóI;ììü#É$Š0…Ææ¥TØ.5­¾gn´ “ÂÖ\:hœ89G)J@„}œ:’Ò{/Š"¦_Æ×7Æ3VÇŠÊa]ÚŒÙ€Ä–=®uÁßâACZƒ§§£Qnâ:«,×{tyø¬iÛcœÜÄ€H½ÄÍCk´÷šß
.W'b¤Íåh]÷€=,Žv×cÚEÚHXJX¶îo¨FÒtèöŸ>ªª6[J®Fµ£sGÁeqõfe\íjÒÐïÄÐGˆe1Ø‹.Ø”‘Ëuø
Y­ˆÜŽG|zùªüMpDnQWÄ”%JŠ™)â*p@Örš«ÕT2Ð%ˆG#ª„
·¤!°ŸOTÂT¸aÚ%4&h™LµšØüÐ.F¿²ÐÞ_Ç‚¾ÅÃaÜ÷09Æ 
q€öy˜v‡85õN÷]¬äѼóS{°_MŽ¬úÔ#°Ç¸0åÞè2ëôPcvÆw9®ií1Ä8F™˜à‰´+‰Ik1òÝ7“Ñ×ÒsÝ\x‚h`ÞÑ`ó"|µEcý£n˜h`}GÞ  !±ù²Ápü²
ß6
0ïi󜵩SÈÇ7˜-ÕURO˜¦´f$ªž-Í6(œ}<„ éc øs]ŽŽ„*—¾
ìdŽ„)méª\¿êÎIg¾ØÞ~I#C/¼¼´EÁÈŽi8“©õådô·>euä ƒ'Ê×लR1ÉJE1ÐAát`t;ÇР%Ý<‡¥„ÍÆ`×Oyó)õiI€ñQaŸ4Ûù\áàaÃÔ¹HÃu¹*k€¦<„eS‡&õÏ
B!ŽhüÞ`yj}mªf×\¿
Ç~æ­9‡û\՞Ǖg²1Žû5V7 !àöšm°
c`ܬøÇìµÒ'P"?…´Ö,"§^•õŽ¨sÔ)6˜sæéÍR¼
ò|Sl”‹7 nPW

Gòú÷½§O¯‡„l¡kSÞŒr½PÊ@æ¢pŽ-mÿ #Ÿ˜Àº¶Áä¦;ïÔæ$1££`“Õ>„—·ž)ß
ð
³ñ#Ï Ô$¶œ‰ÊE‹À;÷º
¯«P:Ñ”8–IÊtpÞ3ª“>ê“þës4ò2OÏÕ­±zô†Õ§‰.÷ä¸;¿˜“'œ›žª}«Œ{ª±Ì 9ÔóÞÕ‡0
$íWV3Üì¬
—@kÝ4@¿r¼±½¬™›?øØæ´'Áé®CË3-g$˜ö‡×auÚi´Žp/êÛæF›Ú2v‹ã¿¿,nB1̨ƃqÞa5͝@&Æû“él÷ \C²½UÍc ¯k×¢U
ÖéQå™—-r    wô ÞÏ<Ò=&=ÿ Ôê Òêˈt,i—;LîÜ á¸*ÚÃ1$êL•LÍ <É)ýÐà’
;F™{ƒ™˜€&'}‚ãÄK`¡ÞT@I;®žZóè‚s’7®°›+§O­Åq©é»²9<Ô
J ¼9O’HL»Ùïì¸rk¼Ž_ý‘TŸu[²ßÚŒ·ü÷B%¯E ŸÔX5êO´Ç•€’I0 É<mÆÈJoúáõóQâØòÙaÙt:  ·=|Ôaz]a1cÉŸ1
4˜à3΍}GFøí7/B«vεŕL=Ðr1ÕšnwH›óÞ¢ºö{)´4€æZç^ÿ yÑ:_([¿ipqQÊ^âÆe;»½“¦º|¢ÀTçèrú1”óTÃ’u¦CG¤ ¡
Š­7ë

·i“¿z»n
ö¼±ù^ö<‹çu7¸ÈlvZðÛAUXje•
dLÞH ÚosÇr`È™‡pÊeÇ4@x7´)ö†Ótœ~i‘Ï[x@äUÃæ­m·e´x
°t¸·²5'žªža   =ÖÌåzϘ'-´ˆpž3§ò‡k  Ý'‰ýÑï¦3ºdè“{eiÔõNkîšECEΠ¥ÃT9ãqÃâŸîɐ8z \?€    >JX` 
ñ¹õ%;µŸD‘«´€àwÒ™UûئžÖö\×®×´8 ½‡ºÐÆÓ§?Àkmœ=;d5*@-ì0F Rªýš[Ü6âö̃ڸr*KA9· u*µæ£?U¸Âêí†8@¦X4 e-ò„0s{ HâUpU?¼mñRa°®a%Ð'tÉ×’\¾ÊÉ]t›h>·(Ë@R¼¡Ãt h}’O÷au<+nT…Ö…MӐ??Óe95 q>í/;&JSû °¯ÊéÞøƒ*Ã2½Ài&:nôUl=¾¿5eˆ3”ñc|Ú2V”>„»&eE;«ÚäC
p¢Ûúy 9š[ŒÌx¼擼A&DåÒ¯ˆ¤ÀÌ;"˜ÏQä¸åhÊ}Ûq«Û0WžÒ|»€ø®öCm5•\ÇÀ§Pe3£]0ÃàLDÉ‰1øªxjgwT‚÷¿LΨK‹›ùs—xˆÜ±µ
kæ¸f‰‰ÜGk/LÛØ6d9ò¶ùA{ƒA3š/¬D¬khÓk‰`˜"㯒r¿±Óã jx‡°e}<Ñø\3y:'À•/h½Í€Ç4~g ?Û(¼]v‘ªlKÎâ~?O‚W%{Ì:“'©úNq¾›úo(X’¥¯ˆ
nFê{Ç€ü?º'ë
ø‹ì
Þ09ŒÌç9Æ —ËC`j@ÓÄ(+a‹un¸#ÂꟋ{K`‘ÑÍÍ'à´»/Û,KW;Þ4²þð ï Nm|~fGÏ(…³Ã)«1ö­Õ
¥‡¨©ƒÃ™ü-s=à=U66Ï«Ýc蓦W¹íž®›nÔ%êÇìŒ<#Ü×84ån®Ð ÒåOC`  ñânÑs‡¢ç 1õ%Îhì½Ã½® e:ݼUZo
™`  
ÅZŸŒÊ«ê1ÏÄo$q¹Þ€©ˆhÐÉä¯ñ[!…Ú˜àJ:x2$Íß&PåT£6ç—
‡Í*4Ýšçjÿ ‰É nófÐ ó(L5C•åÆ\rMÒ@ò
}y-W}™üýVù—ú¢=Ù”c®‘< M ž
´Phr¦©TD ‘ù.$´÷O‡‘V2Æò.=IUŒ=ž‡â¬i™aþÓåÙ?òUø'ØÖ•.~* šTŒ!•-×áºTâ®ä#õü'´ eýlYÅÓeÕKÂrT"CÚ@u!Óxƒ{š3€}1¿(r}%«nËamjÑ%ÑNEò
v  ˜à  σöK³,*º.àzù¨™Ó ÚçâU¦*¿ 9{%Ö¹ njûdaXöb)  kÛƱûÓ\°M7ˆÂ=û›ç¿Ã‚­V»Cg–8ÙêE-j)k$º`Ã-ùEýeBÆÇ]c¡°ñty&Òd0nõ'¡W+ƒ*|–ø<K\%¦cÏÄ#N,Úú‘¤òÒÛõ ’¶§‰Ì
ú•dçb31Ð\7‡ëÚw82
‰KÝkÚñ'¢Ž…[&¼ÌAÔzHàP *اoßreÁY¥Ñ¾ãE|&QbKg]ã„þê*b;R³Öi‹  ±î$£ÈTm¶k÷ˆ
¦»Ù¹i¦¨6 h%Á'Ú
J   \F±â+‹b/Å9ñå5Àë­nˆRv«¯#„&î„$º’@:‘Ôrø+,àq‘秬*Úg´>µFa\GQªEAÔp5\Ǽ·¼Ç8·õ -â§Ú[
‡
uZeÖ 3}×d'+¹:ð+K†Û®s!Ï$úe€<Û”x)1»a­¡LC]¸µík…ÚàA»AYº{†ªS[¦5HÒ7ù
--,ísòDØ€èk   ÞÀîÜò@â(  ËNˆë›4ô½•/¦o‡€Û7
ê•ÆêòðÜy
'Án½µ á˜ݦ  ndeo…[ì¶Ê,¥R³Ä=À±—–ß;£™´ñSâ*g§”ïaið‘Jå~™ÓÞß³Õ¢»8x埒²52>AÊb&-÷\7´éÄù€T˜,w;3{ï˜k…à¹ÄqÀ«œ{
€\
ˆ¾[´¨јr &Úé„Ívˆ±8†¿]|¬ņ4I×pÞS1ÈÖz‰#Ìv‡G!YNògñ:màTz¢Ý1ô©^O=~ë|5Bã™ç•¼µõ•bÆ@úÕS¬ÈŒ#¬zünrŸ
û”
Z²•ï›èðV"ÁHÚý©wÝ €7¼Ìu1hÑa3Éä û f$o¿É ™Ú›ÝçnpÒ3äÌ3†Í§,Äï]$‰/pê†«À¼
¸e9­Æê_C]žƒ·ý·frÁN«,E=›Çq
-‰öŒ:aÏ¿±í&£Í:-}
84‘ÿ eƒQÑeëSsuiA
³g㟥ú£?ÿ ʼn*”“÷aühe:ÊWa@ÒÞk±eØ]
F Ô—r.åä˜@ö¥ªZoÐýYL·¥S²G/‡ñ
<~*ZÆ´è>JlòàÛƽÿ 窘ìGN¢:I®KšJp/`íIÁÀõ#Ä-€ö­šµŒoF4|ÆQØÆ@Ì|£Ô…¢À{9˜è½Üó›€ôYÒÎYsið;ís¤€à²ˆ‚4qÉVŒI$  ‰"°   æµ8cXGjœˏ¡Aâý•ËÜ¢ûïe·çLx']á"oÅÎê3¯Ç—¹”ó0nå‚âg{Œñ>
S´˜îè°g238‚ãköÝfÚd´6Ò€;ò÷±¢™¼›º¢Æ'¥Ðx'e¬ç
]bÈÆV¢ó‹kýBO
ðÊâ$Ÿ!×T
3Mýמ
žìٍàÌü‘8÷€àæØ8æ©6‰©L´«…oãpð„~Çk‰!ñ;‹”ÛžÍ àž±z Ÿôû øŸÝužÏ;ÿ #|u6™Þ¬ÚˆÐõA4¶â|ôl|Ê2ŽÇ¤ÝÅÇY.<#Aí.k§hóF‚”Y;
M½Ö4hŸ4&›­¿tès´%FìL¥£Ãk‰ÇT¤haÁ¤ÚxfÉ`ÑìË›>i 3t‚:,–+^÷´–{Û–Nxi"x‘Ûg
î¨>¥Õ܁ùZH,2Û“:8xÊ¢Çí9.É-Ìâã-=çjwµS˜dütžçwýGòú®®ûº_ˆýx$–¡ãøO
EÚÛÏ÷R„×w+3£Á£öUMyR²¹âŒ°š›¸Ñãò9§Ó_Dl+Ùßc›úšGÅÌc†Ž!Ko=¶.‘Îÿ c²(2®V mª.ÿ ¹B›¹å ù„öŸSV>™ü¯$y:G¢Z×àøúdî¹û­·ýÇ´:•c LÍõi_‹ö+ÎæGÊè>OŠ•äž´§Þ{X}¨1ÚTc›»Qþ•êô°t¿OP?eæ~É{5]•ÙR£r5†nZ\ã@
&îJõ ¾àC°þV>fé¥/ü5ñÊIº_é5;e­h<@
Ä&æÃëE%;X,ÒãÆÞ`Oò¦kŸm#˜!ÀyÄ¢|
óLšò¥Ä`
¶R=|ÈCâh5ò3DˆïF†ðÒ#ÅìÛœ?¸yhBãœí
ZxßÎÄhºRK„`Þödvײ™ÀÈÑÒgŒuYw³%†ƒÓzõ ÖÏp‚dH®¦A´ù§»ÓÇMæ~)ˆð‡û:ù&Ä •vGD´À 
n
Ý
‡¼Ö8Fö   óáà£~Ë¥x`oK|Ä?fxiØü%pìR>éò+Û±éÎ>núlFŤ'tq8LZÏvÃ?„¡ß±È⽆¯³íü@x|PöUäèØã¡ð‚ŒAìÏ"vÍwóŸÍ{ ý0.z    È•Ö{,N¡£¡ŸKÕÙž>Ýœþ ÍÀ<n^Àïe€Þgn¹”ÜiQê
9Ú±‡„è]ËA¿‚MJìiÓxŒn-ÄS6!ÓæÑû*jÎWøìšÇ뙦gj~+?\,Ö7ÁÕÊ”G™q6TF)óCç<ÓšÂUé†gW=àà“hóR³ÊQì<!÷ÇpR1¯u„De,è­vvâDß~žHå‰ú£Kìní¢ÐçÅÄÅ¥Ü÷
±ÃìÇžûƒz\þÞ¨-•‹
€

¸+¶n¿^
?†[ÖWóÒX¸,0Ø:l?‰Âý«ÿ ·Dc+fÔ[ƒ›ûªšx«kæž1KI…<#'nž¶\±íÎ8¤ìK@’@J¥v)º[Ž±Æå´¼
½Ý¡ç¯ÐO¥ø®è•Óȱ߿wša©“œt‡4îyªœ&+1ÏØ:‚æƒ=/ꎔ`hm
“=©‹]°g}ì€DgUƒ8¤qCˆãáÅ,‡Ô¬ñ10HÑDÂbáÂÿ Œ»v·:uòB6»áp‰>°<×EA!Å‚D™IúOÍ
¡>ôG}Â`ÍßkÜL™Ž  Þð™
{IøF²
¹òQ3&!ÃÂÞz.d&Ï-sH¸,Ôõ˜ŽP€
77ˆÝ¼ÊëÜw   =cÕ
Ú,ØÐ5ÎYÐ)ì´öœgŒ[¤
ßv㙑8心>h]§µháYš£²ºÑ.{Ï7Sð•?´~×SÃKýJÛ˜
™Íäiúu<µX¶1õ^kâçIÑ£sZ4h>j*ÔšD:4­¿_ ÷¸
Õxæÿ ¸?Mù _•­ÊÐ ä ÷ý ÑwL
œ­ïnTkÛUÍN©ë:¦fV ¶ÜÔÜMªÅâA½–¿R×TXš-%iTÊT•‡Ù‚JôϐZxWÑè‰f‰òG º
×Õû2aZ7OU3[“×AT–ÞŒ…-‘¤”Ì 
ì&(ˆ¿­•ƒkï’:ðY¦W‘Å)“†‘˜³Åtcø˜ñTÂwÚÇ4
|üLÇªí–v-
qˆèU
qPE.†â‘˜µ Æ,ÐÅs]8¾„oúÑ i>ÜxxÈó)ƒ ´æÁâØ$À‰vžŸf$Ž|ãw;ÀÁIJ»b`
{¦Ó¤Ú$©YÀ‘n@Óïž«9J¼êG   m¤
ܯ¹ÌW4€ÐÒÅÛ‡#褕Ÿn-?í|с¥÷Ú¹¬'´ÞÜ9ÓK`hê£SÄSà?7—Wí_´…óB›»:=Ãïq`<8ñÓŒÑlú2d¬ê³£hÖ[l|$vÝro~'R®‰§°ñmY ͧäP
|PUª¹·:3Œ[Û{Xÿ ºâ@‚W–Äé u‚ ¯´*=íή.pûÒdt @
G‰¬ s¸    ëÉücr ÞæѨÊ@>¤¢Ö±.Þ'¯°ÌME[YéïĵÂCå½
Ué©Áû'Ê9%eÔðNU”ë‘ÌsD3/®+UI˜9h.WC”
빓$#:pz:YÓ ¿xž* ³$Í +$kñAŠ‹†¢
Uê>¸)_š¬÷©ßAÂÔb9ÇU ¯¾
á•9¯ÏÏ÷O÷¼¼Fähal1‰3Ì[Ïr•´UCksNÐ]R‘¸¥H+§Šé†c©vÖÞ0iÓ76s†î!§=ß
¼~Ô'°Ãmäoäš³ªøi1úÉ)³yV8CLÄØÁ‘WYïi€H6ÖÑiámø^ÈY´°Ñ7¥Û*—Ñ©L«Qƒï—Ùrÿ ›£Ð*š¸ˆL©ˆ$ˆ ÷¾D§9È®«qbqC)–ˆïv´çñsÑVT­Ø, <àïºÀO«Jý·õ 
àfPìð  .wFšir´þ’2_Y
*Æ€x\«
ì€9š@ Ž|F⇥ˆkZ@hÖÄ0t¿-<“‹qµ¾*ZL¤Ú)&BJpÓF5=$„at*Zš$’ÑtdûÝRI1    2Ž‰$€$I$#‰SÞ’H
ë¬ï;Á$¡t$’`<(ñÇt)$‡Ð.Êf¢X’Kt=Éé$‚ˆªè¢oÝëòI%Rgcª÷ŠyI%¡‰ÿ !ñ)´õ $¤ Ô’IIGÿÙa

�3�gO��@s�dd
lZdd
l
Z
dd
lZddlmZ
ddlmZ
ed�
ZGdd�de�Ze
j	dd�
d	d
��
Z
dd�Zd
d�ZGdd�dej
�ZGdd�dej
�ZGdd�dej
�Zedkr�e��
d
S)�N)
�
import_module)
�
gc_collect�asyncioc
@seZ
dZd
S)�AwaitExceptionN��__name__�
__module__�__qualname__�r
r
�1/opt/python39/lib/python3.9/test/test_asyncgen.pyr
s
rF�
�throwc


cs|rd
V
ndV
dS)Nr�
�resultr
rr
r
r�	awaitables
rc

Cshd
}
z"|
rd
}
|�t
�
}n
|�d�
}Wn.tyT
}
z|jdWYd}~Sd}~00|dkrd}
qdS)NFr
rT)r
r�send�
StopIteration�args)�coro�exc�fut�exr
r
r�run_until_completes





 
rc
s�f
d
d�}
t|
��
S)Nc�s&g}�2z3dHW}
|�|
�

q6|S�
N�
�append)�res�
i�
�genr
r�iterate's



zto_list.<locals>.iterate)
r)rr r
rr�to_list&s
r!c@s4eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�ZdS)�AsyncGenSyntaxTestc
Cs@d
}
|�t
d��
t|
ii�
Wd�
n1s20


Y
dS)NzJasync def foo():
            await abc
            yield from 123
        �yield from.*inside async��assertRaisesRegex�SyntaxError�exec��self�coder
r
r�test_async_gen_syntax_012s

z+AsyncGenSyntaxTest.test_async_gen_syntax_01c
Cs@d
}
|�t
d��
t|
ii�
Wd�
n1s20


Y
dS)Nz4async def foo():
            yield from 123
        r#r$r(r
r
r�test_async_gen_syntax_02;s

z+AsyncGenSyntaxTest.test_async_gen_syntax_02c
Cs@d
}
|�t
d��
t|
ii�
Wd�
n1s20


Y
dS)NzXasync def foo():
            await abc
            yield
            return 123
        �return.*value.*async genr$r(r
r
r�test_async_gen_syntax_03Cs

z+AsyncGenSyntaxTest.test_async_gen_syntax_03c
Cs@d
}
|�t
d��
t|
ii�
Wd�
n1s20


Y
dS)NzBasync def foo():
            yield
            return 123
        r-r$r(r
r
r�test_async_gen_syntax_04Ms

z+AsyncGenSyntaxTest.test_async_gen_syntax_04c
Cs@d
}
|�t
d��
t|
ii�
Wd�
n1s20


Y
dS)NzWasync def foo():
            if 0:
                yield
            return 12
        r-r$r(r
r
r�test_async_gen_syntax_05Vs

z+AsyncGenSyntaxTest.test_async_gen_syntax_05N)rrr	r+r,r.r/r0r
r
r
rr"0s
	
	r"c@steZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�ZdS)�AsyncGenTestcCs0d
d�}dd�}||
�
}||�
}|�||�
|S)Nc

Ssrg}
z|
�|�
��

Wqty6


|
�d
�

YqnYqtyj
}
z|
�tt|�
�
�

WYd}~qd}~00q|
S)N�STOP)r�__next__r�	Exception�str�type)�
grrr
r
r�sync_iterateds







*
z5AsyncGenTest.compare_generators.<locals>.sync_iteratec

Ss�g}
|��}z�z|�
�
Wqtyx
}
zF|jrN|
�|jd
�

WYd}~q�n|
�d�

WYd}~q�WYd}~qd}~0ty�


�Yqty�
}
z*|
�tt|�
�
�

WYd}~q�WYd}~qd}~00qWqty�


|
�d�

Yq�Yq0q|
S)Nr
zEMPTY StopIterationr2)	�	__anext__r3rrr�StopAsyncIterationr4r5r6)r7r�anrr
r
r�
async_iterateps(








 




(




z6AsyncGenTest.compare_generators.<locals>.async_iterate)
�assertEqual)r)�sync_gen�	async_genr8r<Zsync_gen_resultZasync_gen_resultr
r
r�compare_generatorscs



zAsyncGenTest.compare_generatorsc
s&�f
d
d�}
��t
|
��
gd�
�
dS)Nc
sFt�IdH
d
V}��
|d�
t�IdH
dV
t�IdH
dV
dS)N�{��
�)rZassertIs)
�
a�
r)r
rr�s






z5AsyncGenTest.test_async_gen_iteration_01.<locals>.gen)rArBrC)r=r!�r)rr
rEr�test_async_gen_iteration_01�s
	z(AsyncGenTest.test_async_gen_iteration_01c

Cs�d
d�}
|
�}|��}|�
�}|�|��d�
z|��
Wn6typ
}
z|�|jdd�
WYd}~nd}~00|�d�

|�
�}|�|��d�
z|��
Wn0ty�
}
z|�|j�

WYd}~nd}~00|�d�

dS)NcSs"t�IdH
d
V
t�IdH
dS�NrA�
rr
r
r
rr�s


z5AsyncGenTest.test_async_gen_iteration_02.<locals>.genrr
rA�StopIteration was not raisedz!StopAsyncIteration was not raised)	�	__aiter__r9r=r3rr�failr:�assertFalse�r)rr7Zair;rr
r
r�test_async_gen_iteration_02�s"





(




"z(AsyncGenTest.test_async_gen_iteration_02c
Cs@d
d�}
|�t
�
�
t|
��

Wd�
n1s20


Y
dS)NcSs,t�IdH
d
V
tdd�
IdH
dV
dS)NrATrrBrIr
r
r
rr�s



z5AsyncGenTest.test_async_gen_exception_03.<locals>.gen)�assertRaisesrr!rFr
r
r�test_async_gen_exception_03�s

z(AsyncGenTest.test_async_gen_exception_03c

Cs�d
d�}
|
�}|��}|�
�}|�|��d�
z|��
Wn6typ
}
z|�|jdd�
WYd}~nd}~00|�d�

|�t�
�
|�
���
Wd�
n1s�0


Y
dS)NcSst�IdH
d
V
dd
dS)NrA�
r
rIr
r
r
rr�s


z5AsyncGenTest.test_async_gen_exception_04.<locals>.genrr
rArJ)	rKr9r=r3rrrLrP�ZeroDivisionErrorrNr
r
r�test_async_gen_exception_04�s






(

z(AsyncGenTest.test_async_gen_exception_04c
CsBd
d�}
|�t
d��
t|
��

Wd�
n1s40


Y
dS)Nc
Ssd
V
t�
dSrH)
r:r
r
r
rr�s

z5AsyncGenTest.test_async_gen_exception_05.<locals>.genz#async generator.*StopAsyncIteration�r%�RuntimeErrorr!rFr
r
r�test_async_gen_exception_05�s


�z(AsyncGenTest.test_async_gen_exception_05c
CsBd
d�}
|�t
d��
t|
��

Wd�
n1s40


Y
dS)Nc
Ssd
V
t�
dSrH)
rr
r
r
rr�s

z5AsyncGenTest.test_async_gen_exception_06.<locals>.genzasync generator.*StopIterationrUrFr
r
r�test_async_gen_exception_06�s


�z(AsyncGenTest.test_async_gen_exception_06c
Cs$d
d�}
dd�}|�|
�|��
dS)Ncss8zd
V
d
d
WdV
dV
ndV
dV
0dV
dS�NrRr
���dr
r
r
r
rr>�s




�
z:AsyncGenTest.test_async_gen_exception_07.<locals>.sync_gencSs8zd
V
d
d
WdV
dV
ndV
dV
0dV
dSrYr
r
r
r
rr?�s




�
z;AsyncGenTest.test_async_gen_exception_07.<locals>.async_gen�
r@�r)r>r?r
r
r�test_async_gen_exception_07�s


z(AsyncGenTest.test_async_gen_exception_07c
Cs$d
d�}
dd�}|�|
�|��
dS)Ncss@zd
V
WdV
d
d
dV
ndV
d
d
dV
0dV
dS�NrRrZr
r[r\r
r
r
r
rr>
s



�

z:AsyncGenTest.test_async_gen_exception_08.<locals>.sync_gencSsdz6d
V
t�IdH
Wt�IdH
dV
d
d
dV
n"t�IdH
dV
d
d
dV
0dV
dSr`rIr
r
r
rr?

s





�


z;AsyncGenTest.test_async_gen_exception_08.<locals>.async_genr]r^r
r
r�test_async_gen_exception_08�s

z(AsyncGenTest.test_async_gen_exception_08c
Cs$d
d�}
dd�}|�|
�|��
dS)Ncss8zd
V
d
d
WdV
dV
ndV
dV
0dV
dSrYr
r
r
r
rr>
s




�
z:AsyncGenTest.test_async_gen_exception_09.<locals>.sync_gencSs\z6t�IdH
d
V
d
d
WdV
t�IdH
dV
ndV
t�IdH
dV
0dV
dSrYrIr
r
r
rr?#
s






�

z;AsyncGenTest.test_async_gen_exception_09.<locals>.async_genr]r^r
r
r�test_async_gen_exception_09
s

z(AsyncGenTest.test_async_gen_exception_09c
CsHd
d�}
|�t
d�� 
|
����d�

Wd�
n1s:0


Y
dS)Nc
Ss
d
V
dSrHr
r
r
r
rr2
s
z5AsyncGenTest.test_async_gen_exception_10.<locals>.genz!non-None value .* async generatorr\)r%�	TypeErrorr9rrFr
r
r�test_async_gen_exception_101
s


�z(AsyncGenTest.test_async_gen_exception_10c
s<d
d��
�
f
dd�}
dd���f
dd�}|�|
�|��
dS)	Nc
ssd
V
dV
dS�N�
�r
r
r
r
rr>9
s

z:AsyncGenTest.test_async_gen_exception_11.<locals>.sync_genc
3sJd
V
��}|�d�

z|�
t��

Wnty>


dV
Yn0dV
dS�NrRrZr[)rr
�
GeneratorExit)
�sg)
r>r
r�sync_gen_wrapper=
s








zBAsyncGenTest.test_async_gen_exception_11.<locals>.sync_gen_wrapperc
Ssd
V
dV
dSrer
r
r
r
rr?G
s

z;AsyncGenTest.test_async_gen_exception_11.<locals>.async_genc
sVd
V
��}|�d�
IdH
z|�
t��
IdH
WntyJ


dV
Yn0dV
dSrh)�asend�athrowri)
Zasg)
r?r
r�async_gen_wrapperK
s







zCAsyncGenTest.test_async_gen_exception_11.<locals>.async_gen_wrapperr])r)rkrnr
)r?r>r�test_async_gen_exception_118
s



z(AsyncGenTest.test_async_gen_exception_11c
Cs�d
d�}
|
�}|�|j
d�
d|_
|�|j
d�
|�d|j�
d|_|�|jd�
|�|j�

|�|jtj	�
|�
|j�

|�|jtj
�
|�t�|���
�

dS)Nc
Ss
d
V
dSrHr
r
r
r
rrX
s
z/AsyncGenTest.test_async_gen_api_01.<locals>.genrZ123z.gen)r=r�assertInr	ZassertIsNone�ag_await�assertIsInstance�ag_frame�types�	FrameTyperM�
ag_running�ag_code�CodeTypeZ
assertTrue�inspectZisawaitable�aclose)r)rr7r
r
r�test_async_gen_api_01W
s







z"AsyncGenTest.test_async_gen_api_01N)rrr	r@rGrOrQrTrWrXr_rarbrdror{r
r
r
rr1as+
		r1c@s<
eZ
dZd
d�Zdd�Zdd�Zdd�Zd	d
�Zdd�Zd
d�Z	dd�Z
dd�Zdd�Zdd�Z
dd�Zdd�Zdd�Zdd�Zdd �Zd!d"�Zd#d$�Zd%d&�Zd'd(�Zd)d*�Zd+d,�Zd-d.�Zd/d0�Zd1d2�Zd3d4�Zd5d6�Zd7d8�Zd9d:�Zd;d<�Z d=d>�Z!d?d@�Z"dAdB�Z#dCdD�Z$dEdF�Z%dGdH�Z&dIdJ�Z'dKdL�Z(dMS)N�AsyncGenAsyncioTestc

Cst�
�|_t�d�

dSr)rZnew_event_loop�loopZset_event_looprEr
r
r�setUpo
s


zAsyncGenAsyncioTest.setUpc

Cs|j�
�
d|_t�d�

dSr)r}�closerZset_event_loop_policyrEr
r
r�tearDowns
s



zAsyncGenAsyncioTest.tearDownc�s&g}|
2z3dHW}|�|�

q6|Srr)r)rrrr
r
rr!x
s



zAsyncGenAsyncioTest.to_listc
Cs0d
d�}
|j�
|�|
��
�
}|�|ddg�
dS)NcSs0d
V
t�
d�
IdH
dV
t�
d�
IdH
dS)NrR�{�G�z�?rZr[�r�sleepr
r
r
rr
s





z:AsyncGenAsyncioTest.test_async_gen_asyncio_01.<locals>.genrRrZ�r}rr!r=)r)rrr
r
r�test_async_gen_asyncio_01~
s

z-AsyncGenAsyncioTest.test_async_gen_asyncio_01c
CsJd
d�}
|�t
�
�$
|j�|�|
��
�

Wd�
n1s<0


Y
dS)NcSs.d
V
t�
d�
IdH
dV
d
d
dV
dS)NrRr�rZr
r[r�r
r
r
rr�
s





z:AsyncGenAsyncioTest.test_async_gen_asyncio_02.<locals>.gen)rPrSr}rr!rFr
r
r�test_async_gen_asyncio_02�
s

z-AsyncGenAsyncioTest.test_async_gen_asyncio_02c
Cs:|j}
Gd
d�d�}|
�
|�|��
�
}|�|ddg�
dS)Nc@seZ
dZd
d�ZdS)z:AsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Genc

Ss d
V
t�
d�
IdH
dV
dS)NrRr�rZr�rEr
r
rrK�
s


zDAsyncGenAsyncioTest.test_async_gen_asyncio_03.<locals>.Gen.__aiter__N)rrr	rKr
r
r
r�Gen�
s
r�rRrZr�)r)r}r�rr
r
r�test_async_gen_asyncio_03�
s

z-AsyncGenAsyncioTest.test_async_gen_asyncio_03c
sDd
d����
fdd�}
��
fdd�}�
j�
|
��

�
j�
|��

dS)NcSsZd
V
t�
d�
IdH
zdV
dV
Wnty>


dV
Yn0t�
d�
IdH
dV
dS)NrRr�rZr[���)rr�rSr
r
r
r�foo�
s









z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.fooc
�s�����}�
�
|��IdHd
�
�
�
|��IdHd�
�
�
|��IdHd�
�
�
|��IdHd�
�
�t�
�
|��IdH
Wd�
n1s�0


Y
�
�t�
�
|��IdH
Wd�
n1s�0


Y
dS)NrRrZr[r�)rKr=r9rPr:�
�it�r�r)r
r�run1�
s






,

zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run1c
�s�����}�
�
|��IdHd
�
�
�
|��IdHd�
z|���t�

Wn6ty~
}

z�
�
|
jdd�
WYd}
~
nd}
~
00�
�d�

�
�
|��IdHd�
�
�t	�
�
|��IdH
Wd�
n1s�0


Y
dS)NrRrZr
r�rJr�)
rKr=r9r
rSrrrLrPr:�r�rr�r
r�run2�
s






(



zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04.<locals>.run2�r}r)r)r�r�r
r�r�test_async_gen_asyncio_anext_04�
s


z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04c
s(d
d����
fdd�}
�
j�
|
��

dS)Nc
Ssd
V}|V}|dV
dS�NrRr\r
�
�
vr
r
rr��
s


z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.fooc
�sD
����}z|�
��d�

Wn6tyR
}

z�
�|
jd
d�
WYd}
~
nd}
~
00�
�d�

z|�
��d�

Wn6ty�
}

z�
�|
jd
d�
WYd}
~
nd}
~
00�
�d�

z|�
��d�

Wn6ty�
}

z�
�|
jd
d�
WYd}
~
nd}
~
00�
�d�

�
�t�
�
|�
�IdH
Wd�
n1�
s60


Y
dS)Nr
rRrJrf�i�)	rKr9rrr=rrLrPr:r�r�r
r�run�
s$




(



(



(

z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05.<locals>.runr��r)r�r
r�r�test_async_gen_asyncio_anext_05�
s
z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05c
s�d
�dd�}
|
�}|�d�

��
t�
�
|�d�

Wd�
n1sF0


Y
�f
dd��
��
�fdd�}�j�|��

���d�
dS)	Nr
cssz
dV
Wn


Yn0dSrr
r
r
r
rr��
s




z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.foocs z
dV
Wn


Yn0d
�dS�NrRr
r
�
�DONEr
rr�
s





z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.genc
�s\�
�}|�d�
IdH
��
t�
� 
|�d�
IdH
Wd�
n1sF0


Y
�d
7�dS�Nrf)rlrPr:�
r7�r�rr)r
rr�s



.
z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06.<locals>.run�)rrPrr}rr=�r)r�r7r�r
r�r�test_async_gen_asyncio_anext_06�
s




(
z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06c
s(d
d����
fdd�}
�
j�
|
��

dS)NcSs(z
d
V
Wnty"


dV
Yn0dS)N�
rR�
rZ�
rSr
r
r
rr�s




zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.fooc�s�����}�
�
|��IdHd
�
�
�t�
�}
|���t�

Wd�
n1sN0


Y
�
�
|
jjdd�
�
�t	�
�
|��IdH
Wd�
n1s�0


Y
dS)Nr�r
r�)
rKr=r9rPrr
rS�	exceptionrr:)r��cmr�r
rr�s



,


zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple.<locals>.runr�r�r
r�r�"test_async_gen_asyncio_anext_tuples

z6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuplec
s(d
d����
fdd�}
�
j�
|
��

dS)NcSs0ztd
�
V
Wnt
y*


td�
V
Yn0dS)NrRr[)rrSr
r
r
rr�%s



zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.fooc�s�����}|�
�IdH}
�
�|
t�
�
�|
jd
�
�
�t�
�}|�
��t�

Wd�
n1s`0


Y
|j	j
d}
�
�|
t�
�
�|
jd�
�
�t�
�
|�
�IdH
Wd�
n1s�0


Y
dS)NrRr
r[)rKr9rrrr=�valuerPr
rSr�rr:)r�r�r�r�r
rr�+s





,




zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration.<locals>.runr�r�r
r�r�*test_async_gen_asyncio_anext_stopiteration$s
z>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiterationc
sRd
d���f
dd�}
|�t
d��
|j�|
��

Wd�
n1sD0


Y
dS)Nc	SsFz(d
V
d
d
Wt�
d�
IdH
dV
nt�
d�
IdH
dV
0dS)NrRr
r�r�r�r
r
r
rr�<s




�
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.fooc�s.��}|��}
|
�
�IdH
|��IdH
dSr�rKr9rz�rr��
r�r
rr�Ds



zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06.<locals>.runz%async generator ignored GeneratorExit)r%rVr}rr�r
r�r� test_async_gen_asyncio_aclose_06;s


�z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06c
s:d
��f
dd��
�
f
dd�}
|j�
|
��

|��d�
dS)Nr
c	srz:d
V
d
d
Wt�
d�
IdH
t�
d�
IdH
�d
7�n*t�
d�
IdH
t�
d�
IdH
�d
7�0�d7�dS)NrRr
r�r�r�r
r�r
rr�Rs





�



zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.fooc�s.��}|��}
|
�
�IdH
|��IdH
dSrr�r�r�r
rr�]s



zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07.<locals>.runrR�r}rr=r�r
)r�r�r� test_async_gen_asyncio_aclose_07Os


z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07c
sfd
�tj
�jd�
���fdd��
�
�fdd�}
�j�|
��

���d�
���
�j�t�d�
�

dS)	Nr
�
r}c	s�zJd
V
�
IdH
�d7�dV
Wt�
d�
IdH
t�
d�
IdH
�d
7�n*t�
d�
IdH
t�
d�
IdH
�d
7�0�d7�dS)NrRr�rZr�r�r
)r�rr
rr�ks







�



zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.fooc�s6��}|��}
�
�
|
��IdHd
�
|��IdH
dSr�)rKr=r9rzr�r�r
rr�xs



zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08.<locals>.runrRr�)r�Futurer}rr=�cancelr�r�r
)r�r�rr)r� test_async_gen_asyncio_aclose_08fs



z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08c
s:d
��f
dd��
�
f
dd�}
|j�
|
��

|��d�
dS)Nr
c	s\z0d
V
qWt�
d�
IdH
t�
d�
IdH
d
�n&t�
d�
IdH
t�
d�
IdH
d
�0dS)NrRr�r�r
r�r
rr�s


�

zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.genc
�s>��}|��IdH
|��IdH
~t
�
t�d
�
IdH
dS)N皙�����?)r9rrr�r�rr
rr��s




zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09.<locals>.runrRr�r�r
�r�rr�#test_async_gen_asyncio_gc_aclose_09�s


	
z7AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09c
s\d
�dd�}
|
�}|�d�

|�
�
�f
dd��
��
fdd�}|j�|��

|��d�
dS)	Nr
cssz
dV
Wn


Yn0dSrr
r
r
r
rr��s




zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.foocs z
dV
Wn


Yn0d
�dSr�r
r
r�r
rr�s





zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.genc
�s0�
�}|�d�
IdH
|�
�IdH
�d
7�dSr�)rlrzr�r�r
rr��s


zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10.<locals>.runr�)rrr}rr=r�r
r�r� test_async_gen_asyncio_aclose_10�s




z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10c
s�d
�dd�}
|
�}|�d�

��
td��
|��
Wd�
n1sF0


Y
�f
dd��
��
�fdd�}�j�|��

���d	�
dS)
Nr
css"z
dV
Wn


Yn0dV
dSrr
r
r
r
rr��s






zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.foo�ignored GeneratorExitcs*z
dV
Wn


Yn0dV
�d
7�dSr�r
r
r�r
rr�s





zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.genc
�s\�
�}|�d�
IdH
��
td
��
|��IdH
Wd�
n1sF0


Y
�d7�dS)Nr�rf)rlr%rVrzr�r�r
rr��s



,
zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11.<locals>.runrf)rr%rVrr}rr=r�r
r�r� test_async_gen_asyncio_aclose_11�s




&	
z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11c
sDd
�dd����fdd��
�
f
dd�}
|j�
|
��

|��d�
dS)	Nr
c�st�
d
�
IdH
dd
dS)Nr�rRr
r�r
r
r
r�target�s

zDAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.targetc
sjt�
�
��
}z0d
V
Wz|IdH
Wqfty:


d
�Yqf0n(z|IdH
Wntyb


d
�Yn00dSr�)r�create_taskrS)
�task)r�r�r
rr��s




�


zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.fooc�s.��}|��}
|
�
�IdH
|��IdH
dSrr�r�r�r
rr��s



zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12.<locals>.runrRr�r�r
)r�r�r�r� test_async_gen_asyncio_aclose_12�s

z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12c
svd
�dd�}
|
�}|�d�
}��
|d�
|�d�
}��
|d�
�f
dd��
�
�fd	d
�}�j�|��

��
�d�
dS)Nr
c
ssd
V}|dV
dS�NrRrZr
r�r
r
r�sgens

zAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.sgenrRr\��c
	s�zjt�
d
�
IdH
dV}t�
d
�
IdH
|dV
t�
d
�
IdH
Wt�
d
�
IdH
t�
d
�
IdH
d�dSt�
d
�
IdH
t�
d
�
IdH
d�0dS�Nr�rRrZr�r�r�r
rrs"








�

�

z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.genc�s|��}|�d�
IdH}
�
�
|
d
�
|�d�
IdH}
�
�
|
d�
�
�t�
� 
|�d�
IdH
Wd�
n1sn0


Y
dS)NrRr\r�)rlr=rPr:�r7r��rr)r
rr�s



z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01.<locals>.run)rr=r}r�r)r�rjr�r�r
r�r�test_async_gen_asyncio_asend_01�s







z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01c
spd
�dd����fdd��
�
�fdd�}
��t
�
�
�j�|
��

Wd�
n1sV0


Y
���d�
dS)	Nr
c

�st�
|�
IdH
d
d
dS�NrRr
r��
�delayr
r
r�
sleep_n_crash,s

zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.sleep_n_crashc
	s�z^t�
d
�
IdH
dV}�
d
�
IdH
�d7�|dV
Wt�
d
�
IdH
t�
d
�
IdH
d�n&t�
d
�
IdH
t�
d
�
IdH
d�0dS�Nr�rRr�rZr�r��r�r�r
rr0s






�

z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.genc�s6��}|�d�
IdH}
�
�
|
d
�
|�d�
IdH
dSr��rlr=r�r�r
rr�=s

z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02.<locals>.runrR)rPrSr}rr=r�r
�r�rr)r�r�test_async_gen_asyncio_asend_02)s


,
z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02c
svd
��f
dd����fdd��
�
�fdd�}
��t
j�
�
�j�|
��

Wd�
n1s\0


Y
���d�
dS)	Nr
c

�s:tj
t�|�
�
jd
���
j�|d�f
dd��
�IdHS)Nr�rZcs���Sr�
r�r
�
rr
r�<lambda>O�z\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crash.<locals>.<lambda>�rZ
ensure_futurer�r}Z
call_laterr�rEr�rr�Ls


�
zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.sleep_n_crashc
	s�z^t�
d
�
IdH
dV}�
d
�
IdH
�d7�|dV
Wt�
d
�
IdH
t�
d
�
IdH
d�n&t�
d
�
IdH
t�
d
�
IdH
d�0dSr�r�r�r�r
rrRs






�

z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.genc�s6��}|�d�
IdH}
�
�
|
d
�
|�d�
IdH
dSr�r�r�r�r
rr�_s

z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03.<locals>.runrR)rPr�CancelledErrorr}rr=r�r
r�r�test_async_gen_asyncio_asend_03Is


,
z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03c
s�d
�Gdd�dt��
�
f
dd�}
|
�}|�
d�
}��|d�
|��
�
}��|d�
��t�
�
|�
d�

Wd�
n1s|0


Y
��
fdd	���
��fd
d�}�j�|��

���d�
dS)Nr
c
@seZ
dZd
S)zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.FooErNrr
r
r
r�FooErns
r�c
3s0z
d
V}Wn�y 


d}Yn0|dV
dS)NrRr�rZr
r�)
r�r
rr�rs







zBAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.sgenrR��c
	s�z�t�
d
�
IdH
z
dV}Wn&�
yB


d}t�
d
�
IdH
Yn0|dV
t�
d
�
IdH
Wt�
d
�
IdH
t�
d
�
IdH
d�n&t�
d
�
IdH
t�
d
�
IdH
d�0dSr�r�r�)r�r�r
rr�s











�

zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.genc�s|�
�}|�d�
IdH}
��
|
d
�
|���
IdH}
��
|
d�
��t�
� 
|�d�
IdH
Wd�
n1sn0


Y
dS)NrRr�)rlr=rmrPr:r�)r�rr)r
rr��s



zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01.<locals>.run)r4rr=r
rPrr}rr�r
�r�r�rr)r� test_async_gen_asyncio_athrow_01ks








(
z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01c
s�d
�Gdd�dt��
�f
dd����
�fdd����
��fdd	�}
��
tj�
�
�j�|
��

Wd�
n1sr0


Y
���d
�
dS)Nr
c
@seZ
dZd
S)zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.FooErNrr
r
r
rr��s
r�c

�s:tj
t�|�
�
jd
���
j�|d�f
dd��
�IdHS)Nr�rZcs���Srr�r
r�r
rr��r�z]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crash.<locals>.<lambda>r�r�rEr�rr��s


�
zKAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.sleep_n_crashc
	s�z~t�
d
�
IdH
z
dV}Wn �
y<


�d
�
IdH
Yn0|dV
t�
d
�
IdH
Wt�
d
�
IdH
t�
d
�
IdH
d�n&t�
d
�
IdH
t�
d
�
IdH
d�0dSr�r�r�)r�r�r�r
rr�s










�

zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.genc�sh��}|�d�
IdH}
��
|
d
�
z|��
�
IdH
Wn"tjyX


��
�d
�
�Yn0��d�

dS)NrRzCancelledError was not raised)rlr=rmrr�rLr�r�r
rr��s





zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02.<locals>.runrR)r4rPrr�r}rr=r�r
)r�r�rr)r�r� test_async_gen_asyncio_athrow_02�s

,
z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02c
s�d
�dd�}
|
�}|�d�

��
t�
�
|�t�

Wd�
n1sF0


Y
�f
dd��
��
�fdd�}�j�|��

���d�
dS)	Nr
cssz
dV
Wn


Yn0dSrr
r
r
r
rr��s




zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.foocs z
dV
Wn


Yn0d
�dSr�r
r
r�r
rr�s





zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.genc
�s\�
�}|�d�
IdH
��
t�
� 
|�t�
IdH
Wd�
n1sF0


Y
�d
7�dSr�)rlrPr:rm�
ValueErrorr�r�r
rr��s



.
zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03.<locals>.runr�)rrPrr
r�r}rr=r�r
r�r� test_async_gen_asyncio_athrow_03�s




(
z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03c
s(d
d����
fdd�}
�
j�
|
��

dS)NcSs(z
d
V
Wnty"


dV
Yn0dS�NrRr�r�r
r
r
rr�s




zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.genc�s|��}|�d�
IdH}
�
�
|
d
�
|�t�
IdH}
�
�
|
d�
�
�t�
� 
|�d�
IdH
Wd�
n1sn0


Y
dSr�)rlr=rmrSrPr:r�r�r
rr��s






zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple.<locals>.runr�r�r
r�r�#test_async_gen_asyncio_athrow_tuple�s
	z7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuplec
s(d
d����
fdd�}
�
j�
|
��

dS)NcSs,z
d
V
Wnty&


t
d�
V
Yn0dSr�)rSrr
r
r
rrs




zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.genc�s���}|�d�
IdH}
�
�
|
d
�
|�t�
IdH}
�
�|
t�
�
�
|
jd�
�
�t�
� 
|�d�
IdH
Wd�
n1s|0


Y
dSr�)	rlr=rmrSrrrr�rPr:r�r�r
rr�
s







zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration.<locals>.runr�r�r
r�r�+test_async_gen_asyncio_athrow_stopiterations

z?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiterationc
s�d
��f
dd��
�
f
dd�}
|j�
|
��
}|j�
|
��
}|j�t�d�
�

|��
|��
|�tj�
�
|j�|�

Wd�
n1s�0


Y
|�tj�
�
|j�|�

Wd�
n1s�0


Y
|j�|j���

|�	�d�
dS)Nr
c

	sRz2t�
|�
IdH
d
V
Wt�
d�
IdH
�d
7�nt�
d�
IdH
�d
7�0dSr�r�)
�timeout)
�	finalizedr
r�waiters



�
zFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waiterc
�s�d
�
2z3dHW}q6dSr�r
)
�
_)
r�r
r�wait"s

zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01.<locals>.waitr�rZ)
r}r�rrr�r�rPr�Zshutdown_asyncgensr=)r)r��t1�t2r
)r�r�r�"test_async_gen_asyncio_shutdown_01s
	


*

*z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01c
sHg��f
d
d��dd�}
|
��
��
fdd�}t�
|��

|��g�
dS)Ncs��|
�

dSrr�r}�context�
�messagesr
r�exception_handler;s
zQAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.exception_handlerc
Ssd
V
dV
dSr�r
r
r
r
rr<>s

zMAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.async_iteratec�s.t�
�}|���

�
2z3dHW}

q*q6dSr�rZget_running_loopZset_exception_handler�r}r�r�r�r
r�mainCs



zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02.<locals>.main�rr�r=)r)r<r�r
�r�r�r�r�"test_async_gen_asyncio_shutdown_028s

z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02c
srg��f
d
d��dd�}
|
��
��
fdd�}t�
|��

�\
}|�|d�
�
|�|dt�
|�d	|d
�
dS)Ncs��|
�

dSrrr�r�r
rr�Qs
z[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.exception_handlercSs(zd
V
dV
Wd
d
n
d
d
0dS�NrRrZr
r
r
r
r
rr<Ts


zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.async_iteratec�s.t�
�}|���

�
2z3dHW}

q*q6dSrr�r�r�r
rr�\s



zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01.<locals>.mainZasyncgenr�z:an error occurred during closing of asynchronous generator�message)rr�r=rrrSrp)r)r<r�r�r
r�r�,test_async_gen_asyncio_shutdown_exception_01Ns





�z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01c
s\g��f
d
d��
dd����
fdd�}
t�
|
��

�\
}|�|dt�
|�d|d	�
dS)
Ncs��|
�

dSrrr�r�r
rr�ns
z[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.exception_handlercSs(zd
V
dV
Wd
d
n
d
d
0dSr�r
r
r
r
rr<qs


zWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.async_iteratec�s0t�
�}|��
�

��2z3dHW}

q,q6dSrr�r��r<r�r
rr�xs



zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02.<locals>.mainr�z1unhandled exception during asyncio.run() shutdownr�)rr�rrrSrp)r)r�r�r
�r<r�r�r�,test_async_gen_asyncio_shutdown_exception_02ks



�z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02c
sLd
d���f
dd��
�
f
dd�}
|j�
|
��
}|�|dd�td	�
D�
�
dS)
Nc
Ss(t|�
D]}
t
�d
�
IdH
|
V
qdS�Nr�)�rangerr�)�
nrr
r
r�arange�s


z@AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.arangec

sd
d��|�
2�
S)Nc
Ss |z3dHW}
|
d
V
q6dS�NrZr
��.0rr
r
r�	<genexpr>�r�zXAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arange.<locals>.<genexpr>r
�
r�)
r�r
r�make_arange�szEAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.make_arangec�sd
d��d�
2�
IdHS)Nc
�sg|z3dHW}
|
�q6Srr
r

r
r
r�
<listcomp>�r�zQAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.run.<locals>.<listcomp>rfr
r
�
r
r
rr��s
z=AsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.runc
Ssg|]}
|
d�qSr�r
r

r
r
rr
�r�zDAsyncGenAsyncioTest.test_async_gen_expression_01.<locals>.<listcomp>rf�r}rr=r��r)r�rr
)r�r
r�test_async_gen_expression_01�s


z0AsyncGenAsyncioTest.test_async_gen_expression_01c
sNd
d��
�
f
dd���f
dd�}
|j�
|
��
}|�|dd�td	d
�D�
�
dS)Nc

�st�
d
�
IdH
|Sr�r�r
r
r
r�wrap�s

z>AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.wrapc

s�f
d
d�t|�
D�
S)Nc
s$|]}
�|
�
IdHr|
d
V
qdSr
r
r

�
r
r
rr
�r�zXAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arange.<locals>.<genexpr>)
r�r
r
r
rr
�szEAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.make_arangec�sd
d��d�
2�
IdHS)Nc
�sg|z3dHW}
|
�q6Srr
r

r
r
rr
�r�zQAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.run.<locals>.<listcomp>rfr
r
r
r
rr��s
z=AsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.runc
Ssg|]}
|
d�qSr�r
r

r
r
rr
�r�zDAsyncGenAsyncioTest.test_async_gen_expression_02.<locals>.<listcomp>rRrfr
r	
r
)r
r
r�test_async_gen_expression_02�s


z0AsyncGenAsyncioTest.test_async_gen_expression_02c
sBg��f
d
d��
dd����
fdd�}
t�
|
��

|�g��
dS)Ncs��|
�

dSrrr�r�r
rr��s
z]AsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.exception_handlerc
Ssd
V
dV
dSr�r
r
r
r
rr<�s

zYAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.async_iteratec�s0t�
�}|��
�

��2z3dHW}

q,q6dSrr�r�r�r
rr��s



zPAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable.<locals>.mainr�)r)r�r
r�r�.test_asyncgen_nonstarted_hooks_are_cancellable�szBAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellablec
s(d
d����
fdd�}
�
j�
|
��

dS)Nc
Ssd
V
dV
dSr�r
r
r
r
rr<�s

zUAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.async_iteratec�s`��}|��}
|
IdH
�
�
td
��
|
IdH
Wd�
n1sD0


Y
|��IdH
dS)Nz4cannot reuse already awaited __anext__\(\)/asend\(\))r9r%rVrz�r�Znxt�r<r)r
rr��s






�(zKAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice.<locals>.runr�r�r
r
r�*test_async_gen_await_same_anext_coro_twice�s
z>AsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twicec
s(d
d����
fdd�}
�
j�
|
��

dS)Nc
Ssd
V
dV
dSr�r
r
r
r
rr<�s

zVAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.async_iteratec�sR��}|��}
|
IdH
�
�
td
��
|
IdH
Wd�
n1sD0


Y
dS)Nz2cannot reuse already awaited aclose\(\)/athrow\(\))rzr%rVr
r
r
rr��s






�zLAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice.<locals>.runr�r�r
r
r�+test_async_gen_await_same_aclose_coro_twice�s

z?AsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twicec
s&d
d���f
dd�}
|j�
|
��

dS)Nc
Ssd
V
dV
dSr�r
r
r
r
rr<�s

z[AsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.async_iteratec
�s&��}|��IdH
|��IdH
dSr�
rzr��
r<r
rr��s


zQAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros.<locals>.runr�r�r
r
r�0test_async_gen_aclose_twice_with_different_coros�szDAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_corosc
s&d
d���f
dd�}
|j�
|
��

dS)Nc
Ssd
V
dV
dSr�r
r
r
r
rr<�s

zQAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.async_iteratec�s,��}|2z3dHW}
q
6|��IdH
dSrr
)r�r�r
r
rr��s



zGAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion.<locals>.runr�r�r
r
r�&test_async_gen_aclose_after_exhaustion�sz:AsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustionc
s&d
d���f
dd�}
|j�
|
��

dS)Nc
Sst�V
dSr)
�objectr
r
r
r�async_generator�s
z\AsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.async_generatorc�s2��}t�
|���

t��}
|
D]}|��
q dSr)rr�rzZ	all_tasksZ	get_stack)ZagZtasksr��
r
r
rr��s




zPAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack.<locals>.runr�r�r
r
r�/test_async_gen_aclose_compatible_with_get_stack�s
zCAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stackN))rrr	r~r�r!r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r�r

r

r
r
r
r
r
r
r
r
r
rr|m
sL*##!%* "5.#"
r|�__main__)ryrtZunittestZtest.supportrrrr4r�	coroutinerrr!ZTestCaser"r1r|rr�r
r
r
r�<module>
s0





1#