o
0i3
@ sB d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z G dd dej Z
G dd dejZedkred e Zee d
eiZd D ] Ze e ee< qTe
eeZdad azd dlZW n e yv Y nw e Z d
e _ e ze W dS e!y trt" st# d
aY qw dS ) 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__ 7/opt/alt/python310/lib64/python3.10/asyncio/__main__.pyr s
z"AsyncIOInteractiveConsole.__init__c sn t j fdd}t| z W S ty ty6 tr/ d Y d S
Y d S w )Nc
s d a dat j} z| }W n8 ty ty1 } zda| W Y d }~d S d }~w tyH } z | W Y d }~d S d }~ww t
|sU | d S zj
|a tt W d S ty| } z | W Y d }~d S d }~ww )NFT) repl_futurerepl_future_interruptedtypes FunctionTyper
SystemExitKeyboardInterruptZ
set_exception
BaseExceptioninspectZ iscoroutineZ
set_resultr
Z create_taskr Z
_chain_future)funccoroZexexccodeZfuturer r r callback s6
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 st z*dt j dt j dtt dd d}tj|dd W tjd d
td t
t j d S tjd d
td t
t j w ) Nz
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...)bannerZexitmsgignorez ^coroutine .* was never awaited$)messagecategory) sysversionplatformgetattrconsoleZinteractwarningsfilterwarningsRuntimeWarningr
r stop)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>
__loader__ __builtins____file__r$ __spec__ __package__FT)$r r8 r Zconcurrent.futuresr r r- Z threadingr r2 r ZInteractiveConsoler ZThreadr( r$ auditZnew_event_loopr
Zset_event_loopZ repl_localskeyr r1 r r readline ImportErrorZ repl_threadZdaemonstartZ run_foreverr ZdoneZcancelr r r r sR 6