JFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrJFIFxxC      C  " }!1AQa"q2#BR$3br %&'()*456789:CDEFGHIJSTUVWXYZcdefghijstuvwxyz w!1AQaq"2B #3RbrU e5d@s0ddlZddlZddlmZGdddeZdS)N)TestCasecseZdZdfdd ZddZddZdd Zd d Zd d ZddZ ddZ ddZ ddZ ddZ ddZddZd fdd ZZS)!IsolatedAsyncioTestCaserunTestcst|d|_d|_dSN)super__init___asyncioTestLoop_asyncioCallsQueue)selfZ methodName __class__+/usr/lib64/python3.8/unittest/async_case.pyr"s z IsolatedAsyncioTestCase.__init__csdSrrr rrr asyncSetUp'sz"IsolatedAsyncioTestCase.asyncSetUpcsdSrrrrrr asyncTearDown*sz%IsolatedAsyncioTestCase.asyncTearDowncOs|j|f||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 _callTearDownCs z%IsolatedAsyncioTestCase._callTearDowncOs|j|f||dSrr)r Zfunctionrrrrr _callCleanupGsz$IsolatedAsyncioTestCase._callCleanupcOs0|||}|j}|j||f|j|Sr)r create_futurer put_nowaitrun_until_completer rrrretfutrrrrJs  z"IsolatedAsyncioTestCase._callAsynccOsB|||}t|r:|j}|j||f|j|S|SdSr)inspectZ isawaitabler rr r r!r"rrrrRs     z'IsolatedAsyncioTestCase._callMaybeAsyncc st|_}|d|IdH}||dkr:dS|\}}z |IdH}|s`||Wqttfk r|Yqt tj fk r}z|s| |W5d}~XYqXqdSr) 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_setupAsyncioLoopos  z)IsolatedAsyncioTestCase._setupAsyncioLoopc Cs|j}d|_|jd||jzt|}|s@WvdS|D] }| qD|tj ||dd|D]0}| r|qn| dk rn| d| |dqn||W5td|XdS)NT)r.Zreturn_exceptionsz(unhandled exception during test shutdown)message exceptiontask)r r r r!joinr&r-closeZ all_tasksZcancelZgatherr(r1Zcall_exception_handlerZshutdown_asyncgens)r r.Z to_cancelr2rrr_tearDownAsyncioLoopys2      z,IsolatedAsyncioTestCase._tearDownAsyncioLoopNcs(|zt|WS|XdSr)r/r5rrun)r resultr rrr6szIsolatedAsyncioTestCase.run)r)N)__name__ __module__ __qualname__rrrrrrrrrrr,r/r5r6 __classcell__rrr rrs  "r)r&r%Zcaserrrrrrs