U
e5d
@ sJ d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z G dd dej Z
G dd dejZedkrFe Zee d eiZd
D ]Ze e ee< qe
eeZdad az d dlZW n ek
r Y nX e Z d e _ e z e W n6 e k
r> tr6t! s6t" d aY qY qX qFqdS )
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__ (/usr/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__asyncio> __builtins____spec__r$ __file__
__loader__ __package__FT)#r r8 r Zconcurrent.futuresr r r1 Z threadingr r- r ZInteractiveConsoler ZThreadr( r$ Znew_event_loopr
Zset_event_loopZ repl_localskeyr r5 r r readline ImportErrorZ repl_threadZdaemonstartZ run_foreverr ZdoneZcancelr r r r sF 6