a XC?h3 �@sTddlZddlZddlZddlZddlZddlZddlZddlZddl Z ddl mZGdd�dej�Z Gdd�dej�Zedk�rPe�d �e��Ze�e�d eiZdD]Ze�eee<q�e ee�ZdadazddlZWney�Yn0e�Zd e_e��ze� �Wn6e!�yFt�r.callbackz KeyboardInterrupt )� concurrentrZFuturer �call_soon_threadsafe�resultrrr�writeZ showtraceback)rrrrrr�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&r6rrrrr(Dsr(�__main__zcpython.run_stdin�asyncio>�__package__�__file__�__spec__r$�__builtins__� __loader__FT)$r r8rZconcurrent.futuresrrr-Z threadingrr2�rZInteractiveConsolerZThreadr(r$�auditZnew_event_loopr Zset_event_loopZrepl_locals�keyrr1rr�readline�ImportErrorZrepl_threadZdaemon�startZrun_foreverrZdoneZcancelrrrr�sH6