Server : LiteSpeed
System : Linux ncr1.int3rnet.net 4.18.0-553.123.2.lve.el8.x86_64 #1 SMP Thu May 7 23:17:13 UTC 2026 x86_64
User : digitaln ( 1704)
PHP Version : 8.1.34
Disable Function : NONE
Directory : /lib64/python3.9/asyncio/__pycache__/
|
Server : LiteSpeed System : Linux ncr1.int3rnet.net 4.18.0-553.123.2.lve.el8.x86_64 #1 SMP Thu May 7 23:17:13 UTC 2026 x86_64 User : digitaln ( 1704) PHP Version : 8.1.34 Disable Function : NONE Directory : /lib64/python3.9/asyncio/__pycache__/ |
a
�i3
� @ 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<t�"� �s<t�#� d
aY �qY n0 �qP�qdS )� N� )�futuresc s$ e Zd Z� fdd�Zdd� Z� ZS )�AsyncIOInteractiveConsolec s* t � �|� | jj jtjO _|| _d S )N)�super�__init__�compileZcompiler�flags�astZPyCF_ALLOW_TOP_LEVEL_AWAIT�loop)�self�localsr
�� __class__� �(/usr/lib64/python3.9/asyncio/__main__.pyr s z"AsyncIOInteractiveConsole.__init__c sp t j�� �� ��fdd�}t�|� z
��� W S tyB � Y n* tyj tr^�� d� n��
� Y n0 d S )Nc
s d a dat�� �j�} z
| � }W nt ty4 � Y nb tyf } z da��|� W Y d }~d S d }~0 ty� } z��|� W Y d }~d S d }~0 0 t �
|�s��� |� d S z �j �
|�a t�t �� W n0 t� y� } z��|� W Y d }~n
d }~0 0 d S )NFT)� repl_future�repl_future_interrupted�types� FunctionTyper �
SystemExit�KeyboardInterrupt�
set_exception�
BaseException�inspectZ iscoroutine�
set_resultr
Z create_taskr Z
_chain_future)�func�coro�ex�exc��code�futurer r r �callback s,
z3AsyncIOInteractiveConsole.runcode.<locals>.callbackz
KeyboardInterrupt
) �
concurrentr �Futurer
�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+ r; r r r r r- D s r- �__main__zcpython.run_stdin�asyncio> �__file__�
__loader__r) � __package__� __builtins__�__spec__FT)$r r= r �concurrent.futuresr# r r2 � threadingr r7 � r ZInteractiveConsoler �Threadr- r) �auditZnew_event_loopr
Zset_event_loopZ repl_locals�keyr r6 r r �readline� ImportErrorZ repl_thread�daemon�startZ run_foreverr �done�cancelr r r r �<module> sH 6