£Á°èZ¨Ä…–K§‚«“ô4“ÒÙ´dîfUÙÃÅ WKbyʦ•êŽ…È®FÒ¿ÊÎóCozá¬S@6{Í:›œêZÌ:Š•_%:¢¾¾~;‘Ã~芩ÊǍí`ÔÑ©ú뙵'5I¿fš×WO%ø9¾«¾DK|€ùÍD”Ýs]nHÕ¶êםӼ㞪éUWŸÈË%DÒÕ¬ï‘]/Åcx ‰ï2ß]ä6G[]S£Ôϯrs{úëóµmÒï#UQxo·õÞCe]"±/aÙ&Eã4ú9Jé_ÞåëdãöKë)AÞ ¯¹ægƒÛowЍø^d™ý½ßB7áyMä9ÜÖUã !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!! a XC?h@s0ddlZddlZddlmZGdddeZdS)N)TestCasecseZdZd#fdd ZddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ ddZddZd$fdd Zfdd Zd!d"ZZS)%IsolatedAsyncioTestCaserunTestcst|d|_d|_dSN)super__init___asyncioTestLoop_asyncioCallsQueue)selfZ methodName __class__8/opt/alt/python39/lib64/python3.9/unittest/async_case.pyr!s z IsolatedAsyncioTestCase.__init__csdSrrr rrr asyncSetUp&sz"IsolatedAsyncioTestCase.asyncSetUpcsdSrrrrrr asyncTearDown)sz%IsolatedAsyncioTestCase.asyncTearDowncOs|j|g|Ri|dSr)Z addCleanup)r funcargskwargsrrraddAsyncCleanup,s z'IsolatedAsyncioTestCase.addAsyncCleanupcCs|||jdSr)ZsetUp _callAsyncrrrrr _callSetUp;sz"IsolatedAsyncioTestCase._callSetUpcCs||dSr_callMaybeAsync)r methodrrr_callTestMethod?sz'IsolatedAsyncioTestCase._callTestMethodcCs||j|dSr)rrZtearDownrrrr _callTearDownBs z%IsolatedAsyncioTestCase._callTearDowncOs|j|g|Ri|dSrr)r Zfunctionrrrrr _callCleanupFsz$IsolatedAsyncioTestCase._callCleanupcOs4||i|}|j}|j||f|j|Sr)r create_futurer put_nowaitrun_until_completer rrrretfutrrrrIs z"IsolatedAsyncioTestCase._callAsynccOsF||i|}t|r>|j}|j||f|j|S|SdSr)inspectZ isawaitabler rr r r!r"rrrrQs    z'IsolatedAsyncioTestCase._callMaybeAsyncc st|_}|d|IdH}||dur:dS|\}}z |IdH}|s`||WqttfyzYqt tj fy}z|s| |WYd}~qd}~00qdSr) asyncioZQueuer Z set_resultgetZ task_done cancelled SystemExitKeyboardInterrupt BaseExceptionZCancelledErrorZ set_exception)r r$ZqueueZqueryZ awaitabler#Zexrrr_asyncioLoopRunner[s   z*IsolatedAsyncioTestCase._asyncioLoopRunnercCsJt}t||d||_|}||||_| |dS)NT) r&Znew_event_loopset_event_loopZ set_debugr rZ create_taskr,Z_asyncioCallsTaskr!)r loopr$rrr_setupAsyncioLoopns  z)IsolatedAsyncioTestCase._setupAsyncioLoopc Cs|j}d|_|jd||jzt|}|s^W||td| dS|D] }| qb|tj |ddi|D]0}| rq| dur|d| |dq||W||td| n"||td| 0dS)NZreturn_exceptionsTz(unhandled exception during test shutdown)message exceptiontask)r r r r!joinr&Z all_tasksZshutdown_default_executorr-closeZcancelZgatherr(r1Zcall_exception_handlerZshutdown_asyncgens)r r.Z to_cancelr2rrr_tearDownAsyncioLoopxsB         z,IsolatedAsyncioTestCase._tearDownAsyncioLoopNcs.|zt|W|S|0dSr)r/rrunr5)r resultr rrr6s  zIsolatedAsyncioTestCase.runcs|t|dSr)r/rdebugr5rr rrr8s zIsolatedAsyncioTestCase.debugcCs|jdur|dSr)r r5rrrr__del__s zIsolatedAsyncioTestCase.__del__)r)N)__name__ __module__ __qualname__rrrrrrrrrrr,r/r5r6r8r9 __classcell__rrr rrs   $ r)r&r%Zcaserrrrrrs