/usr/lib/python3.10/unittest/__pycache__
Edit: /usr/lib/python3.10/unittest/__pycache__/async_case.cpython-310.pyc (4746B)
o
…9jà ã @ s0 d dl Z d dlZddlmZ G dd„ deƒZdS )é Né )ÚTestCasec s e Zd Zd#‡ fdd„ Zdd„ Zdd„ Zdd „ Zd
d „ Zd d
„ Zdd„ Z dd„ Z
dd„ Z dd„ Z dd„ Z
dd„ Zdd„ Zd$‡ fd d „ Z‡ fd d „Zd!d"„ Z‡ ZS )%ÚIsolatedAsyncioTestCaseÚrunTestc s t ƒ |¡ d | _d | _d S ©N)ÚsuperÚ__init__Ú_asyncioTestLoopÚ_asyncioCallsQueue)ÚselfÚ
methodName©Ú __class__© ú*/usr/lib/python3.10/unittest/async_case.pyr ! s
z IsolatedAsyncioTestCase.__init__c à ó d S r r ©r r r r Ú
asyncSetUp& ó €z"IsolatedAsyncioTestCase.asyncSetUpc à r r r r r r r Ú
asyncTearDown) r z%IsolatedAsyncioTestCase.asyncTearDownc O ó | j |g|¢R i |¤Ž d S r )Ú
addCleanup)r ÚfuncÚargsÚkwargsr r r ÚaddAsyncCleanup, s
z'IsolatedAsyncioTestCase.addAsyncCleanupc C s | ¡ | | j¡ d S r )ÚsetUpÚ
_callAsyncr r r r r Ú
_callSetUp; s z"IsolatedAsyncioTestCase._callSetUpc C s | |¡ d S r ©Ú_callMaybeAsync)r Úmethodr r r Ú_callTestMethod? s z'IsolatedAsyncioTestCase._callTestMethodc C s | | j¡ | ¡ d S r )r r ÚtearDownr r r r Ú
_callTearDownB s z%IsolatedAsyncioTestCase._callTearDownc O r r r )r Úfunctionr r r r r Ú _callCleanupF s z$IsolatedAsyncioTestCase._callCleanupc O s^ | j d us J dƒ‚||i |¤Ž}t |¡s J |›dƒ‚| j ¡ }| j ||f¡ | j |¡S )Nú$asyncio test loop is not initializedz returned non-awaitable©r ÚinspectÚ isawaitableÚ
create_futurer
Ú
put_nowaitÚrun_until_complete©r r r r ÚretÚfutr r r r I s
z"IsolatedAsyncioTestCase._callAsyncc O sT | j d us J dƒ‚||i |¤Ž}t |¡r(| j ¡ }| j ||f¡ | j |¡S |S )Nr' r( r. r r r r Q s
z'IsolatedAsyncioTestCase._callMaybeAsyncc
à s¸ t ¡ | _}| d ¡ | ¡ I d H }| ¡ |d u r d S |\}}z|I d H }| ¡ s2| |¡ W n' ttfy= ‚ t t j
fyZ } z| ¡ sP| |¡ W Y d }~nd }~ww qr ) ÚasyncioÚQueuer
Ú
set_resultÚgetÚ task_doneÚ cancelledÚ
SystemExitÚKeyboardInterruptÚ
BaseExceptionÚCancelledErrorÚ
set_exception)r r0 ÚqueueÚqueryÚ awaitabler/ Úexr r r Ú_asyncioLoopRunner[ s, €
€
€þôz*IsolatedAsyncioTestCase._asyncioLoopRunnerc C s\ | j d u s J dƒ‚t ¡ }t |¡ | d¡ || _ | ¡ }| | |¡¡| _| |¡ d S )Nz%asyncio test loop already initializedT)
r r1 Únew_event_loopÚset_event_loopÚ set_debugr+ Ú create_taskr@ Ú_asyncioCallsTaskr- )r Úloopr0 r r r Ú_setupAsyncioLoopn s
z)IsolatedAsyncioTestCase._setupAsyncioLoopc
C s$ | j d us J dƒ‚| j }d | _ | j d ¡ | | j ¡ ¡ zct |¡}|s8W | | ¡ ¡ t d ¡ | ¡ d S |D ]}|
¡ q:| tj |ddiŽ¡ |D ]}| ¡ rUqN|
¡ d urf| d|
¡ |dœ¡ qN| | ¡ ¡ W | | ¡ ¡ t d ¡ | ¡ d S | | ¡ ¡ t d ¡ | ¡ w )Nr' Úreturn_exceptionsTz(unhandled exception during test shutdown)ÚmessageÚ exceptionÚtask)r r
r, r- Újoinr1 Ú all_tasksÚshutdown_default_executorrB ÚcloseÚcancelÚgatherr6 rJ Úcall_exception_handlerÚshutdown_asyncgens)r rF Ú to_cancelrK r r r Ú_tearDownAsyncioLoopx sD
ë
ÿ ý€
þ
z,IsolatedAsyncioTestCase._tearDownAsyncioLoopNc s* | ¡ z tƒ |¡W | ¡ S | ¡ w r )rG r ÚrunrU )r Úresultr
r r rV œ s zIsolatedAsyncioTestCase.runc s | ¡ tƒ ¡ | ¡ d S r )rG r ÚdebugrU r r
r r rX £ s
z IsolatedAsyncioTestCase.debugc C s | j d ur | ¡ d S d S r )r rU r r r r Ú__del__¨ s
ÿz IsolatedAsyncioTestCase.__del__)r r )Ú__name__Ú
__module__Ú __qualname__r r r r r r" r$ r& r r r@ rG rU rV rX rY Ú
__classcell__r r r
r r s"
$ r )r1 r) Úcaser r r r r r Ú
s