a zeO@sddlZddlZddlZddlmZddlmZedZGdddeZej ddd d Z d d Z d dZ Gdddej ZGdddej ZGdddej ZedkredS)N) import_module) gc_collectasyncioc@s eZdZdS)AwaitExceptionN__name__ __module__ __qualname__r r F/opt/bitninja-python-dojo/embedded/lib/python3.9/test/test_asyncgen.pyr srFthrowccs|r dVndVdS)Nr resultr r r r r awaitablesrc Cshd}z"|rd}|t}n |d}Wn.tyT}z|jdWYd}~Sd}~00|dkrd}qdS)NFrr T)r rsend StopIterationargs)coroexcfutexr r r run_until_completes  rcsfdd}t|S)Ncs&g}2z3dHW}||q6|SNappend)resigenr r iterate'szto_list..iterate)r)rr r rr to_list&s r!c@s4eZdZddZddZddZddZd d Zd S) AsyncGenSyntaxTestcCs@d}|tdt|iiWdn1s20YdS)NzJasync def foo(): await abc yield from 123 yield from.*inside asyncassertRaisesRegex SyntaxErrorexecselfcoder r r test_async_gen_syntax_012sz+AsyncGenSyntaxTest.test_async_gen_syntax_01cCs@d}|tdt|iiWdn1s20YdS)Nz4async def foo(): yield from 123 r#r$r(r r r test_async_gen_syntax_02;sz+AsyncGenSyntaxTest.test_async_gen_syntax_02cCs@d}|tdt|iiWdn1s20YdS)NzXasync def foo(): await abc yield return 123 return.*value.*async genr$r(r r r test_async_gen_syntax_03Csz+AsyncGenSyntaxTest.test_async_gen_syntax_03cCs@d}|tdt|iiWdn1s20YdS)NzBasync def foo(): yield return 123 r-r$r(r r r test_async_gen_syntax_04Msz+AsyncGenSyntaxTest.test_async_gen_syntax_04cCs@d}|tdt|iiWdn1s20YdS)NzWasync def foo(): if 0: yield return 12 r-r$r(r r r test_async_gen_syntax_05Vsz+AsyncGenSyntaxTest.test_async_gen_syntax_05N)rrr r+r,r.r/r0r r r r r"0s    r"c@steZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZdS) AsyncGenTestcCs0dd}dd}||}||}||||S)Nc Ssrg}z||Wqty6|dYqnYqtyj}z|tt|WYd}~qd}~00q|S)NSTOP)r__next__r Exceptionstrtype)grrr r r sync_iterateds  *z5AsyncGenTest.compare_generators..sync_iteratec Ssg}|}zz |Wqtyx}zF|jrN||jdWYd}~qn|dWYd}~qWYd}~qd}~0tyYqty}z*|tt|WYd}~qWYd}~qd}~00qWqty|dYqYq0q|S)NrzEMPTY StopIterationr2) __anext__r3rrrStopAsyncIterationr4r5r6)r7ranrr r r async_iterateps(    (   z6AsyncGenTest.compare_generators..async_iterate) assertEqual)r)sync_gen async_genr8r<Zsync_gen_resultZasync_gen_resultr r r compare_generatorscs   zAsyncGenTest.compare_generatorscs&fdd}t|gddS)NcsFtIdHdV}|dtIdHdVtIdHdVdS)N{)rZassertIs)ar)r r rs    z5AsyncGenTest.test_async_gen_iteration_01..gen)rArBrC)r=r!r)rr rEr test_async_gen_iteration_01s z(AsyncGenTest.test_async_gen_iteration_01c Csdd}|}|}|}||dz |Wn6typ}z||jddWYd}~nd}~00|d|}||dz |Wn0ty}z||jWYd}~nd}~00|ddS)NcSs"tIdHdVtIdHdSNrArr r r r rs z5AsyncGenTest.test_async_gen_iteration_02..genrrrAStopIteration was not raisedz!StopAsyncIteration was not raised) __aiter__r9r=r3rrfailr: assertFalser)rr7Zair;rr r r test_async_gen_iteration_02s" (  "z(AsyncGenTest.test_async_gen_iteration_02cCs@dd}|tt|Wdn1s20YdS)NcSs,tIdHdVtddIdHdVdS)NrATr rBrIr r r r rs z5AsyncGenTest.test_async_gen_exception_03..gen) assertRaisesrr!rFr r r test_async_gen_exception_03s z(AsyncGenTest.test_async_gen_exception_03c Csdd}|}|}|}||dz |Wn6typ}z||jddWYd}~nd}~00|d|t|Wdn1s0YdS)NcSstIdHdVdddS)NrArrIr r r r rs z5AsyncGenTest.test_async_gen_exception_04..genrrrArJ) rKr9r=r3rrrLrPZeroDivisionErrorrNr r r test_async_gen_exception_04s (  z(AsyncGenTest.test_async_gen_exception_04cCsBdd}|tdt|Wdn1s40YdS)NcSsdVtdSrH)r:r r r r rsz5AsyncGenTest.test_async_gen_exception_05..genz#async generator.*StopAsyncIterationr% RuntimeErrorr!rFr r r test_async_gen_exception_05s z(AsyncGenTest.test_async_gen_exception_05cCsBdd}|tdt|Wdn1s40YdS)NcSsdVtdSrH)rr r r r rsz5AsyncGenTest.test_async_gen_exception_06..genzasync generator.*StopIterationrUrFr r r test_async_gen_exception_06s z(AsyncGenTest.test_async_gen_exception_06cCs$dd}dd}|||dS)Ncss8zdVddWdVdVndVdV0dVdSNrRrdr r r r r r>s z:AsyncGenTest.test_async_gen_exception_07..sync_gencSs8zdVddWdVdVndVdV0dVdSrYr r r r r r?s z;AsyncGenTest.test_async_gen_exception_07..async_genr@r)r>r?r r r test_async_gen_exception_07s  z(AsyncGenTest.test_async_gen_exception_07cCs$dd}dd}|||dS)Ncss@zdVWdVdddVndVdddV0dVdSNrRrZrr[r\r r r r r r>sz:AsyncGenTest.test_async_gen_exception_08..sync_gencSsdz6dVtIdHWtIdHdVdddVn"tIdHdVdddV0dVdSr`rIr r r r r? s  z;AsyncGenTest.test_async_gen_exception_08..async_genr]r^r r r test_async_gen_exception_08s  z(AsyncGenTest.test_async_gen_exception_08cCs$dd}dd}|||dS)Ncss8zdVddWdVdVndVdV0dVdSrYr r r r r r>s z:AsyncGenTest.test_async_gen_exception_09..sync_gencSs\z6tIdHdVddWdVtIdHdVndVtIdHdV0dVdSrYrIr r r r r?#s    z;AsyncGenTest.test_async_gen_exception_09..async_genr]r^r r r test_async_gen_exception_09s  z(AsyncGenTest.test_async_gen_exception_09cCsHdd}|td |dWdn1s:0YdS)NcSs dVdSrHr r r r r r2sz5AsyncGenTest.test_async_gen_exception_10..genz!non-None value .* async generatorr\)r% TypeErrorr9rrFr r r test_async_gen_exception_101s z(AsyncGenTest.test_async_gen_exception_10cs<ddfdd}ddfdd}|||dS) NcssdVdVdSN r r r r r r>9sz:AsyncGenTest.test_async_gen_exception_11..sync_genc3sJdV}|dz|tWnty>dVYn0dVdSNrRrZr[)rr GeneratorExit)sg)r>r r sync_gen_wrapper=s   zBAsyncGenTest.test_async_gen_exception_11..sync_gen_wrappercSsdVdVdSrer r r r r r?Gsz;AsyncGenTest.test_async_gen_exception_11..async_gencsVdV}|dIdHz|tIdHWntyJdVYn0dVdSrh)asendathrowri)Zasg)r?r r async_gen_wrapperKs  zCAsyncGenTest.test_async_gen_exception_11..async_gen_wrapperr])r)rkrnr )r?r>r test_async_gen_exception_118s   z(AsyncGenTest.test_async_gen_exception_11cCsdd}|}||jdd|_||jd|d|jd|_||jd||j||jtj | |j ||j tj |t|dS)NcSs dVdSrHr r r r r rXsz/AsyncGenTest.test_async_gen_api_01..genrZ123z.gen)r=rassertInr Z assertIsNoneag_awaitassertIsInstanceag_frametypes FrameTyperM ag_runningag_codeCodeTypeZ assertTrueinspectZ isawaitableaclose)r)rr7r r r test_async_gen_api_01Ws  z"AsyncGenTest.test_async_gen_api_01N)rrr r@rGrOrQrTrWrXr_rarbrdror{r r r r r1as+    r1c@s<eZdZddZddZddZddZd d Zd d Zd dZ ddZ ddZ ddZ ddZ ddZddZddZddZdd Zd!d"Zd#d$Zd%d&Zd'd(Zd)d*Zd+d,Zd-d.Zd/d0Zd1d2Zd3d4Zd5d6Zd7d8Zd9d:Zd;d<Z d=d>Z!d?d@Z"dAdBZ#dCdDZ$dEdFZ%dGdHZ&dIdJZ'dKdLZ(dMS)NAsyncGenAsyncioTestcCst|_tddSr)rZnew_event_looploopZset_event_looprEr r r setUpos zAsyncGenAsyncioTest.setUpcCs|jd|_tddSr)r}closerZset_event_loop_policyrEr r r tearDownss zAsyncGenAsyncioTest.tearDowncs&g}|2z3dHW}||q6|Srr)r)rrrr r r r!xszAsyncGenAsyncioTest.to_listcCs0dd}|j||}||ddgdS)NcSs0dVtdIdHdVtdIdHdS)NrR{Gz?rZr[rsleepr r r r rs z:AsyncGenAsyncioTest.test_async_gen_asyncio_01..genrRrZr}rr!r=)r)rrr r r test_async_gen_asyncio_01~sz-AsyncGenAsyncioTest.test_async_gen_asyncio_01cCsJdd}|t$|j||Wdn1s<0YdS)NcSs.dVtdIdHdVdddVdS)NrRrrZrr[rr r r r rs z:AsyncGenAsyncioTest.test_async_gen_asyncio_02..gen)rPrSr}rr!rFr r r test_async_gen_asyncio_02s z-AsyncGenAsyncioTest.test_async_gen_asyncio_02cCs:|j}Gddd}|||}||ddgdS)Nc@seZdZddZdS)z:AsyncGenAsyncioTest.test_async_gen_asyncio_03..GencSs dVtdIdHdVdS)NrRrrZrrEr r r rKszDAsyncGenAsyncioTest.test_async_gen_asyncio_03..Gen.__aiter__N)rrr rKr r r r GensrrRrZr)r)r}rrr r r test_async_gen_asyncio_03sz-AsyncGenAsyncioTest.test_async_gen_asyncio_03csDddfdd}fdd}j|j|dS)NcSsZdVtdIdHzdVdVWnty>dVYn0tdIdHdVdS)NrRrrZr[)rrrSr r r r foos   z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04..foocs}|IdHd|IdHd|IdHd|IdHdt|IdHWdn1s0Yt|IdHWdn1s0YdS)NrRrZr[r)rKr=r9rPr:itrr)r r run1s  , zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04..run1c s}|IdHd|IdHdz|tWn6ty~}z|jddWYd}~nd}~00d|IdHdt |IdHWdn1s0YdS)NrRrZrrrJr) rKr=r9r rSrrrLrPr:rrrr r run2s (  zAAsyncGenAsyncioTest.test_async_gen_asyncio_anext_04..run2r}r)r)rrr rr test_async_gen_asyncio_anext_04s   z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_04cs(ddfdd}j|dS)NcSsdV}|V}|dVdSNrRr\r vr r r rsz@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05..fooc sD}z|dWn6tyR}z|jddWYd}~nd}~00dz|dWn6ty}z|jddWYd}~nd}~00dz|dWn6ty}z|jddWYd}~nd}~00dt|IdHWdn1s60YdS)NrrRrJrf i) rKr9rrr=rrLrPr:rrr r runs$ ( ( (  z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05..runrr)rr rr test_async_gen_asyncio_anext_05sz3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_05csddd}|}|dt|dWdn1sF0Yfddfdd}j|ddS) Nrcssz dVWn Yn0dSrr r r r r rs z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06..foocs z dVWn Yn0ddSNrRr r DONEr r rs  z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06..gencs\}|dIdHt |dIdHWdn1sF0Yd7dSNrf)rlrPr:r7rrr)r r rs  .z@AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06..run )rrPrr}rr=r)rr7rr rr test_async_gen_asyncio_anext_06s  ( z3AsyncGenAsyncioTest.test_async_gen_asyncio_anext_06cs(ddfdd}j|dS)NcSs(z dVWnty"dVYn0dS)NrRrZrSr r r r rs  zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple..foocs}|IdHdt}|tWdn1sN0Y|jjddt |IdHWdn1s0YdS)Nrrr) rKr=r9rPrr rS exceptionrr:)rcmrr r rs  , zCAsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuple..runrrr rr "test_async_gen_asyncio_anext_tuples z6AsyncGenAsyncioTest.test_async_gen_asyncio_anext_tuplecs(ddfdd}j|dS)NcSs0ztdVWnty*tdVYn0dS)NrRr[)rrSr r r r r%s zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration..foocs}|IdH}|t|jdt}|tWdn1s`0Y|j j d}|t|jdt |IdHWdn1s0YdS)NrRrr[) rKr9rrrr=valuerPr rSrrr:)rrrrr r r+s   ,   zKAsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiteration..runrrr rr *test_async_gen_asyncio_anext_stopiteration$sz>AsyncGenAsyncioTest.test_async_gen_asyncio_anext_stopiterationcsRddfdd}|td|j|Wdn1sD0YdS)Nc SsFz(dVddWtdIdHdVntdIdHdV0dS)NrRrrrrr r r r r<s zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06..foocs.}|}|IdH|IdHdSrrKr9rzrrrr r rDszAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06..runz%async generator ignored GeneratorExit)r%rVr}rrr rr test_async_gen_asyncio_aclose_06;s z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_06cs:dfddfdd}|j||ddS)Nrc srz:dVddWtdIdHtdIdHd7n*tdIdHtdIdHd70d7dS)NrRrrrrr rr r rRs   zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07..foocs.}|}|IdH|IdHdSrrrrr r r]szAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07..runrRr}rr=rr )rrr test_async_gen_asyncio_aclose_07Os  z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_07csfdtjjdfddfdd}j|djtddS) Nrr}c szJdVIdHd7dVWtdIdHtdIdHd7n*tdIdHtdIdHd70d7dS)NrRrrZrrr )rrr r rks   zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08..foocs6}|}|IdHd|IdHdSr)rKr=r9rzrrr r rxszAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08..runrRr)rFuturer}rr=cancelrrr )rrrr)r test_async_gen_asyncio_aclose_08fs  z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_08cs:dfddfdd}|j||ddS)Nrc s\z0dVqWtdIdHtdIdHdn&tdIdHtdIdHd0dS)NrRrrr rr r rs zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09..gencs>}|IdH|IdH~ttdIdHdS)N皙?)r9rrrrrr r rs zDAsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09..runrRrrr rrr #test_async_gen_asyncio_gc_aclose_09s  z7AsyncGenAsyncioTest.test_async_gen_asyncio_gc_aclose_09cs\ddd}|}|d|fddfdd}|j||ddS) Nrcssz dVWn Yn0dSrr r r r r rs zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10..foocs z dVWn Yn0ddSrr r rr r rs  zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10..gencs0}|dIdH|IdHd7dSr)rlrzrrr r rszAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10..runr)rrr}rr=rr rr test_async_gen_asyncio_aclose_10s  z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_10csddd}|}|dtd|Wdn1sF0Yfddfdd}j|d dS) Nrcss"z dVWn Yn0dVdSrr r r r r rs  zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11..fooignored GeneratorExitcs*z dVWn Yn0dVd7dSrr r rr r rs  zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11..gencs\}|dIdHtd|IdHWdn1sF0Yd7dS)Nrrf)rlr%rVrzrrr r rs ,zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11..runrf)rr%rVrr}rr=rr rr test_async_gen_asyncio_aclose_11s & z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_11csDdddfddfdd}|j||ddS) NrcstdIdHdddS)NrrRrrr r r r targetszDAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12..targetcsjt}z0dVWz|IdHWqfty:dYqf0n(z|IdHWntybdYn00dSr)r create_taskrS)task)rrr r rs    zAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12..foocs.}|}|IdH|IdHdSrrrrr r rszAAsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12..runrRrrr )rrrr test_async_gen_asyncio_aclose_12s  z4AsyncGenAsyncioTest.test_async_gen_asyncio_aclose_12csvddd}|}|d}|d|d}|dfddfd d }j|ddS) NrcssdV}|dVdSNrRrZr rr r r sgenszAAsyncGenAsyncioTest.test_async_gen_asyncio_asend_01..sgenrRr\c szjtdIdHdV}tdIdH|dVtdIdHWtdIdHtdIdHddStdIdHtdIdHd0dSNrrRrZrrrr r r s" z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01..gencs|}|dIdH}|d|dIdH}|dt |dIdHWdn1sn0YdS)NrRr\r)rlr=rPr:r7rrr)r r rs   z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01..run)rr=r}rr)rrjrrr rr test_async_gen_asyncio_asend_01s      z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_01cspdddfddfdd}tj|Wdn1sV0YddS) Nrcst|IdHdddSNrRrrdelayr r r sleep_n_crash,szJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_02..sleep_n_crashc sz^tdIdHdV}dIdHd7|dVWtdIdHtdIdHdn&tdIdHtdIdHd0dSNrrRrrZrrrrr r r0s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02..gencs6}|dIdH}|d|dIdHdSrrlr=rrr r r=s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02..runrR)rPrSr}rr=rr rrr)rr test_async_gen_asyncio_asend_02)s  ,z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_02csvdfddfddfdd}tjj|Wdn1s\0YddS) Nrcs:tjt|jdj|dfddIdHS)NrrZcsSrrr rr r Oz\AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03..sleep_n_crash..rZ ensure_futurerr}Z call_laterrrErr rLs  zJAsyncGenAsyncioTest.test_async_gen_asyncio_asend_03..sleep_n_crashc sz^tdIdHdV}dIdHd7|dVWtdIdHtdIdHdn&tdIdHtdIdHd0dSrrrrr r rRs z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03..gencs6}|dIdH}|d|dIdHdSrrrrr r r_s z@AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03..runrR)rPrCancelledErrorr}rr=rr rr test_async_gen_asyncio_asend_03Is  ,z3AsyncGenAsyncioTest.test_async_gen_asyncio_asend_03csdGdddtfdd}|}|d}|d|}|dt|dWdn1s|0Yfdd fd d }j|ddS) Nrc@s eZdZdS)zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01..FooErNrr r r r FooErnsrc3s0z dV}Wny d}Yn0|dVdS)NrRrrZr r)rr r rrs    zBAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01..sgenrRc sztdIdHz dV}Wn&yBd}tdIdHYn0|dVtdIdHWtdIdHtdIdHdn&tdIdHtdIdHd0dSrrr)rrr r rs   zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01..gencs|}|dIdH}|d|IdH}|dt |dIdHWdn1sn0YdS)NrRr)rlr=rmrPr:r)rrr)r r rs   zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01..run)r4rr=r rPrr}rrr rrrr)r test_async_gen_asyncio_athrow_01ks      ( z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_01csdGdddtfddfddfdd }tjj|Wdn1sr0Yd dS) Nrc@s eZdZdS)zCAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02..FooErNrr r r r rsrcs:tjt|jdj|dfddIdHS)NrrZcsSrrr rr r rrz]AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02..sleep_n_crash..rrrErr rs  zKAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02..sleep_n_crashc sz~tdIdHz dV}Wn y<dIdHYn0|dVtdIdHWtdIdHtdIdHdn&tdIdHtdIdHd0dSrrr)rrrr r rs   zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02..gencsh}|dIdH}|dz|IdHWn"tjyXdYn 0ddS)NrRzCancelledError was not raised)rlr=rmrrrLrrr r rs  zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02..runrR)r4rPrrr}rr=rr )rrrr)rr test_async_gen_asyncio_athrow_02s ,z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_02csddd}|}|dt|tWdn1sF0Yfddfdd}j|ddS) Nrcssz dVWn Yn0dSrr r r r r rs zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03..foocs z dVWn Yn0ddSrr r rr r rs  zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03..gencs\}|dIdHt |tIdHWdn1sF0Yd7dSr)rlrPr:rm ValueErrorrrr r rs  .zAAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03..runr)rrPrr rr}rr=rr rr test_async_gen_asyncio_athrow_03s  ( z4AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_03cs(ddfdd}j|dS)NcSs(z dVWnty"dVYn0dSNrRrrr r r r rs  zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple..gencs|}|dIdH}|d|tIdH}|dt |dIdHWdn1sn0YdSr)rlr=rmrSrPr:rrr r rs   zDAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuple..runrrr rr #test_async_gen_asyncio_athrow_tuples z7AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_tuplecs(ddfdd}j|dS)NcSs,z dVWnty&tdVYn0dSr)rSrr r r r rs  zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration..gencs}|dIdH}|d|tIdH}|t|jdt |dIdHWdn1s|0YdSr) rlr=rmrSrrrrrPr:rrr r r s   zLAsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiteration..runrrr rr +test_async_gen_asyncio_athrow_stopiterations z?AsyncGenAsyncioTest.test_async_gen_asyncio_athrow_stopiterationcsdfddfdd}|j|}|j|}|jtd|||tj|j|Wdn1s0Y|tj|j|Wdn1s0Y|j|j| ddS)Nrc sRz2t|IdHdVWtdIdHd7ntdIdHd70dSrr)timeout) finalizedr r waiters zFAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01..waitercsd2z 3dHW}q6dSrr )_)rr r wait"szDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01..waitrrZ) r}rrrrrrPrZshutdown_asyncgensr=)r)rt1t2r )rrr "test_async_gen_asyncio_shutdown_01s **z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_01csHgfdddd}|fdd}t||gdS)Ncs|dSrrr}contextmessagesr r exception_handler;szQAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02..exception_handlercSsdVdVdSrr r r r r r<>szMAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02..async_iteratecs.t}|2z3dHW}q*q6dSrrZget_running_loopZset_exception_handlerr}rrrr r mainCs zDAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02..mainrrr=)r)r<rr rrrr "test_async_gen_asyncio_shutdown_028s  z6AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_02csrgfdddd}|fdd}t|\}||d||dt|d |d dS) Ncs|dSrrrrr r rQsz[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01..exception_handlercSs(zdVdVWddn dd0dSNrRrZrr r r r r r<TszWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01..async_iteratecs.t}|2z3dHW}q*q6dSrrrrr r r\s zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01..mainZasyncgenrz:an error occurred during closing of asynchronous generatormessage)rrr=rrrSrp)r)r<rrr rr ,test_async_gen_asyncio_shutdown_exception_01Ns  z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_01cs\gfddddfdd}t|\}||dt|d|d dS) Ncs|dSrrrrr r rnsz[AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02..exception_handlercSs(zdVdVWddn dd0dSrr r r r r r<qszWAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02..async_iteratecs0t}|2z3dHW}q,q6dSrrrr<rr r rxs zNAsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02..mainrz1unhandled exception during asyncio.run() shutdownr)rrrrrSrp)r)rrr r<rrr ,test_async_gen_asyncio_shutdown_exception_02ks  z@AsyncGenAsyncioTest.test_async_gen_asyncio_shutdown_exception_02csLddfddfdd}|j|}||ddtd DdS) NcSs(t|D]}tdIdH|VqdSNr)rangerr)nrr r r aranges z@AsyncGenAsyncioTest.test_async_gen_expression_01..arangecsdd|2S)NcSs |z3dHW}|dVq6dSNrZr .0rr r r rzXAsyncGenAsyncioTest.test_async_gen_expression_01..make_arange..r r)rr r make_arangeszEAsyncGenAsyncioTest.test_async_gen_expression_01..make_arangecsddd2IdHS)Ncsg|z3dHW}|q6Srr rr r r rzQAsyncGenAsyncioTest.test_async_gen_expression_01..run..rfr r rr r rsz=AsyncGenAsyncioTest.test_async_gen_expression_01..runcSsg|] }|dqSrr rr r r rrzDAsyncGenAsyncioTest.test_async_gen_expression_01..rfr}rr=rr)rrr )rrr test_async_gen_expression_01s   z0AsyncGenAsyncioTest.test_async_gen_expression_01csNddfddfdd}|j|}||ddtd d DdS) NcstdIdH|Srrrr r r wrapsz>AsyncGenAsyncioTest.test_async_gen_expression_02..wrapcsfddt|DS)Ncs$|]}|IdHr|dVqdSrr rr r r rrzXAsyncGenAsyncioTest.test_async_gen_expression_02..make_arange..)rrr r r rszEAsyncGenAsyncioTest.test_async_gen_expression_02..make_arangecsddd2IdHS)Ncsg|z3dHW}|q6Srr rr r r rrzQAsyncGenAsyncioTest.test_async_gen_expression_02..run..rfr r rr r rsz=AsyncGenAsyncioTest.test_async_gen_expression_02..runcSsg|] }|dqSrr rr r r rrzDAsyncGenAsyncioTest.test_async_gen_expression_02..rRrfrr r )rr r test_async_gen_expression_02s   z0AsyncGenAsyncioTest.test_async_gen_expression_02csBgfddddfdd}t||gdS)Ncs|dSrrrrr r rsz]AsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable..exception_handlercSsdVdVdSrr r r r r r<szYAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable..async_iteratecs0t}|2z3dHW}q,q6dSrrrrr r rs zPAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellable..mainr)r)rr rr .test_asyncgen_nonstarted_hooks_are_cancellables   zBAsyncGenAsyncioTest.test_asyncgen_nonstarted_hooks_are_cancellablecs(ddfdd}j|dS)NcSsdVdVdSrr r r r r r<szUAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice..async_iteratecs`}|}|IdHtd|IdHWdn1sD0Y|IdHdS)Nz4cannot reuse already awaited __anext__\(\)/asend\(\))r9r%rVrzrZnxtr<r)r r rs (zKAsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twice..runrrr rr *test_async_gen_await_same_anext_coro_twices z>AsyncGenAsyncioTest.test_async_gen_await_same_anext_coro_twicecs(ddfdd}j|dS)NcSsdVdVdSrr r r r r r<szVAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice..async_iteratecsR}|}|IdHtd|IdHWdn1sD0YdS)Nz2cannot reuse already awaited aclose\(\)/athrow\(\))rzr%rVrrr r rs zLAsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twice..runrrr rr +test_async_gen_await_same_aclose_coro_twices z?AsyncGenAsyncioTest.test_async_gen_await_same_aclose_coro_twicecs&ddfdd}|j|dS)NcSsdVdVdSrr r r r r r<sz[AsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros..async_iteratecs&}|IdH|IdHdSrrzrr<r r rszQAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coros..runrrr rr 0test_async_gen_aclose_twice_with_different_coross zDAsyncGenAsyncioTest.test_async_gen_aclose_twice_with_different_coroscs&ddfdd}|j|dS)NcSsdVdVdSrr r r r r r<szQAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion..async_iteratecs,}|2z 3dHW}q 6|IdHdSrr)rrrr r rszGAsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustion..runrrr rr &test_async_gen_aclose_after_exhaustions z:AsyncGenAsyncioTest.test_async_gen_aclose_after_exhaustioncs&ddfdd}|j|dS)NcSs tVdSr)objectr r r r async_generatorsz\AsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack..async_generatorcs2}t|t}|D] }|q dSr)rrrzZ all_tasksZ get_stack)ZagZtasksrrr r rs zPAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stack..runrrr rr /test_async_gen_aclose_compatible_with_get_stacks zCAsyncGenAsyncioTest.test_async_gen_aclose_compatible_with_get_stackN))rrr r~rr!rrrrrrrrrrrrrrrrrrrrrrrrrrrr r rrrrrrr r r r r|msL   *##!%* "5.#" r|__main__)ryrtZunittestZ test.supportrrrr4r coroutinerrr!ZTestCaser"r1r|rrr r r r s0   1#