a ze �@sFddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl mZGdd�dej�Z Gdd�dej�Zedk�rBe��Ze�e�d eiZd D]Ze�eee<q�e ee�ZdadazddlZWney�Yn0e�Zde_e��ze��Wn4e �y:t�r2t�!��s2t�"�daYq�Yq�0�qBq�dS) �N�)�futurescs$eZdZ�fdd�Zdd�Z�ZS)�AsyncIOInteractiveConsolecs*t��|�|jjjtjO_||_dS)N)�super�__init__�compileZcompiler�flags�astZPyCF_ALLOW_TOP_LEVEL_AWAIT�loop)�self�localsr �� __class__��D/opt/bitninja-python-dojo/embedded/lib/python3.9/asyncio/__main__.pyrsz"AsyncIOInteractiveConsole.__init__csptj��fdd�}t�|�z ��WStyB�Yn*tyjtr^�� d�n�� Yn0dS)Nc sdadat��j�}z |�}Wntty4�Ynbtyf}zda��|�WYd}~dSd}~0ty�}z��|�WYd}~dSd}~00t � |�s��|�dSz�j� |�at�t��Wn0t�y�}z��|�WYd}~n d}~00dS)NFT)�repl_future�repl_future_interrupted�types�FunctionTyper� SystemExit�KeyboardInterrupt� set_exception� BaseException�inspectZiscoroutine� set_resultr Zcreate_taskrZ _chain_future)�func�coro�ex�exc��code�futurerrr�callbacks, z3AsyncIOInteractiveConsole.runcode..callbackz KeyboardInterrupt )� concurrentr�Futurer �call_soon_threadsafe�resultrrr�writeZ showtraceback)rr r"rrr�runcodes z!AsyncIOInteractiveConsole.runcode)�__name__� __module__�__qualname__rr(� __classcell__rrr rrsrc@seZdZdd�ZdS)� REPLThreadcCsvzRdtj�dtj�dttdd��d�}tj|dd�Wtjd d td�t � t j�ntjd d td�t � t j�0dS)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)rr.rrr�runFs* ��zREPLThread.runN)r)r*r+r;rrrrr-Dsr-�__main__�asyncio>�__builtins__�__spec__� __loader__�__package__�__file__r)FT)#r r=r �concurrent.futuresr#rr2� threadingrr7�rZInteractiveConsoler�Threadr-r)Znew_event_loopr Zset_event_loopZrepl_locals�keyrr6rr�readline�ImportErrorZrepl_thread�daemon�startZrun_foreverr�done�cancelrrrr�sF6