�
� Wc
c sd � d dl Z d dlZd dlZd dlZd dlZd dlZd dlZd dlZd dl Z ddl
m Z G d� dej � Z
G d� dej � Zedk r� ej" � Z ej& e� d eiZd
D ] Z e� e ee< � e
ee� Zdad a d dlZ e� Z d e _ e j= � ej? � dS dS # e$ r Y �>w xY w# e $ r8 t0 r.t0 jC � st0 jE � d aY �^w xY w)
i Ni )�futuresc s$ � � e Zd Z� fd�Zd� Z� xZS )�AsyncIOInteractiveConsolec s� �� t � j |� | j j xj t
j z c_ || _ d S )N)Zsuper�__init__ZcompileZcompilerZflags�astZPyCF_ALLOW_TOP_LEVEL_AWAIT�loop)�self�localsr � __class__s ��)/usr/lib64/python3.12/asyncio/__main__.pyr z"AsyncIOInteractiveConsole.__init__ sH �� �
����� � � � � � � �#�#�#�s�'E�'E�E�#�#��� � � � c s8 � ��� t j j � ���� fd�}t j |� �j � S # t $ r � t $ r1 t r� j d� Y d S � j � Y d S w xY w)Nc s: �� d a dat j ��j � } | � }t j |� s�j |� d S �j j |� a t j t �� d S # t
$ r � t $ r }da�j |� Y d }~d S d }~wt $ r }�j |� Y d }~d S d }~ww xY w# t $ r }�j |� Y d }~d S d }~ww xY w)NFT)� repl_future�repl_future_interrupted�typesZ FunctionTyper �
SystemExit�KeyboardInterruptZ
set_exception�
BaseException�inspectZ iscoroutineZ
set_resultr Z create_taskr Z
_chain_future)ZfuncZcoroZexZexc�code�futurer s ���r �callbackz3AsyncIOInteractiveConsole.runcode.<locals>.callback sa �� � �K�&+� #��%�%�d�D�K�K�8�D�
��t�v�� �&�&�t�,�,��!�!�$�'�'���
*� "�i�i� 3� 3�D� 9� ��%�%�k�6�:�:�:�:��! �
�
�
��$�
�
�
�*.�'��$�$�R�(�(����������� �
�
�
��$�$�R�(�(�����������
����� !�
*�
*�
*��$�$�S�)�)�)�)�)�)�)�)�����
*���s; �B � 9C3 �C0�,C�
C0�C+�+C0�3
D�=D�Dz
KeyboardInterrupt
) �
concurrentr ZFuturer �call_soon_threadsafeZresultr
r r ZwriteZ
showtraceback)r r r r s `` @r �runcodez!AsyncIOInteractiveConsole.runcode s� ���� ��#�#�*�*�,�� *� *� *� *� *� *� *�<
�!�!�(�+�+� %��=�=�?� "��� � � � � � %� %� %�&�&��
�
�2�3�3�3�3�3��"�"�$�$�$�$�$� %���s �A �-B�B�B)�__name__�
__module__� __qualname__r r Z
__classcell__)r s @r r r sG �� � � � � �� � � � � +%� +%� +%� +%� +%� +%� +%r r c s � e Zd Zd� ZdS )�
REPLThreadc
s� � dt j � dt j � dt t dd� � d�}t j |d�� t
j d d
t � � t j t j � d S # t
j d d
t � � t j t j � w xY 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...)�bannerZexitmsgZignorez ^coroutine .* was never awaited$)ZmessageZcategory) �sysZversionZplatformZgetattr�consoleZinteract�warningsZfilterwarningsZRuntimeWarningr r Zstop)r r s r �runzREPLThread.runF s� � � 1�?�� � � ?� ?�� � � ?� ?� �3��v�.� ?� ?� ?�
�
� � � �1�
�
3�
3�
� #� #��;�'�
)�
)�
)�
� %� %�d�i�i� 0� 0� 0� 0��
� #� #��;�'�
)�
)�
)�
� %� %�d�i�i� 0� 0� 0� 0� 0� 0s
�AB � AC%N)r r r r � r r r r D s# � � � � � �1� 1� 1� 1� 1r r Z__main__�asyncio> Z__file__r Z__spec__Z
__loader__Z __package__Z __builtins__FT)#r r! r Zconcurrent.futuresr r r Z threadingr r Z r ZInteractiveConsoler ZThreadr r Znew_event_loopr Zset_event_loopZ repl_localsZkeyr r r
r ZreadlineZ ImportErrorZ repl_threadZdaemonZstartZ run_foreverr ZdoneZcancelr r r �<module>r" s ��
�
�
�
� ���� � � � � � � � � ����
�
�
�
� � � � � � � � � ���� � � � � � �3%� 3%� 3%� 3%� 3%�� 7� 7� 3%� 3%�l1� 1� 1� 1� 1��!�!� 1� 1�0 �z��� !�7� !� !� #�D��G���4� � � �g�&�K�,� )� )�� "�6�8�C�=� �C���'�'� �T�:�G��K� #��
����� �*�,�K� �K�������
� � � � � � �
�E�C ���" �
�
�
� ��
����� !� � � ��{�;�#3�#3�#5�#5��"�"�$�$�*.�'� �H� ���s$ �,C' �C2 �'C/�.C/�2:D/�.D/