U
if3
@ sX d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z G dd dej Z
G dd dejZedkrTed e Zee d
eiZd D ]Ze e ee< qe
eeZdad az d dlZW n e k
r Y nX e Z d
e _ e z e W n8 e!k
rJ tr@t" s@t# d
aY qY nX qTqdS ) N )futuresc s$ e Zd Z fddZdd Z ZS )AsyncIOInteractiveConsolec s* t | | jj jtjO _|| _d S )N)super__init__compileZcompilerflagsastZPyCF_ALLOW_TOP_LEVEL_AWAITloop)selflocalsr
__class__ 5/opt/alt/python38/lib64/python3.8/asyncio/__main__.pyr s z"AsyncIOInteractiveConsole.__init__c st t j fdd}t| z
W S tk
rD Y n, tk
rn trb d n
Y nX d S )Nc
s d a dat j} z
| }W nz tk
r6 Y nf tk
rj } zda| W Y d S d }~X Y n2 tk
r } z| W Y d S d }~X Y nX t
|s | d S z j
|a tt W n. tk
r } z| W 5 d }~X Y nX d S )NFT) repl_futurerepl_future_interruptedtypes FunctionTyper
SystemExitKeyboardInterruptZ
set_exception
BaseExceptioninspectZ iscoroutineZ
set_resultr
Z create_taskr Z
_chain_future)funccoroZexexccodeZfuturer r r callback s,
z3AsyncIOInteractiveConsole.runcode..callbackz
KeyboardInterrupt
)
concurrentr ZFuturer
call_soon_threadsaferesultr r r writeZ
showtraceback)r r r r r r runcode s
z!AsyncIOInteractiveConsole.runcode)__name__
__module__ __qualname__r r#
__classcell__r r r
r r s r c @ s e Zd Zdd ZdS )
REPLThreadc C sZ z6dtj dtj dt tdd d }t
j |d
d W 5 t jddtd ttj X d S ) Nignorez ^coroutine .* was never awaited$)messagecategoryz
asyncio REPL z on zy
Use "await" directly instead of "asyncio.run()".
Type "help", "copyright", "credits" or "license" for more information.
Zps1z>>> zimport asynciozexiting asyncio REPL...)bannerZexitmsg) warningsfilterwarningsRuntimeWarningr
r stopsysversionplatformgetattrconsoleZinteract)r r, r r r runF s "
zREPLThread.runN)r$ r% r& r6 r r r r r( D s r( __main__zcpython.run_stdinasyncio> r$ __file__ __package__ __builtins__
__loader____spec__FT)$r r8 r Zconcurrent.futuresr r r1 Z threadingr r- r ZInteractiveConsoler ZThreadr( r$ auditZnew_event_loopr
Zset_event_loopZ repl_localskeyr r5 r r readline ImportErrorZ repl_threadZdaemonstartZ run_foreverr ZdoneZcancelr r r r sH 6