a
XC?h3
� @ sT d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z G dd� dej �Z
G dd� dej�Zedk�rPe�d � e�� Ze�e� d
eiZd D ]Ze� e ee< q�e
ee�Zdad az d dlZW n e y� Y n0 e� Z d
e _ e � � z e� � W n6 e!�yF t�r.callbackz
KeyboardInterrupt
) �
concurrentr ZFuturer
�call_soon_threadsafe�resultr 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 sv zRdt j� dt j� dtt dd�� d�}tj|dd� W tjd d
td � t �
t j � n tjd d
td � t �
t j � 0 d S ) 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...)�bannerZexitmsg�ignorez ^coroutine .* was never awaited$)�message�category) �sys�version�platform�getattr�consoleZinteract�warnings�filterwarnings�RuntimeWarningr
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_stdin�asyncio> � __package__�__file__�__spec__r$ � __builtins__�
__loader__FT)$r r8 r Zconcurrent.futuresr r r- Z threadingr r2 � r ZInteractiveConsoler ZThreadr( r$ �auditZnew_event_loopr
Zset_event_loopZ repl_locals�keyr r1 r r �readline� ImportErrorZ repl_threadZdaemon�startZ run_foreverr ZdoneZcancelr r r r � sH 6