| Server IP : 217.160.0.135 / Your IP : 216.73.217.85 Web Server : Apache System : Linux www 6.18.52-i1-ampere #1203 SMP Mon Sep 14 18:29:59 CEST 2026 aarch64 User : sws1074145052 ( 1074145052) PHP Version : 8.3.32 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /usr/lib/python3/dist-packages/asgiref/__pycache__/ |
Upload File : |
�
"z�c/ � �H � d dl Z d dlZddlmZ ddlmZ G d� d� � ZdS )� N� )�guarantee_single_callable)�timeoutc �D � e Zd ZdZd� Zdd�Zdd�Zd� Zd� Zdd �Z dd �Z
d
S )�ApplicationCommunicatorz}
Runs an ASGI application in a test mode, allowing sending of
messages to it and retrieval of messages it sends.
c � � t |� � | _ || _ t j � � | _ t j � � | _ t j | � || j j | j j � � � � | _
d S �N) r � application�scope�asyncio�Queue� input_queue� output_queue�
ensure_future�get�put�future)�selfr
r s �1/usr/lib/python3/dist-packages/asgiref/testing.py�__init__z ApplicationCommunicator.__init__ sn � �4�[�A�A�����
�"�=�?�?��� #�M�O�O��� �+� � � �U�D�$4�$8�$�:K�:O� P� P�
�
�� � � � r c � �^ K � t |� � 4 �d{V �� | j � d{V �� | j � � � n# t j $ r Y nw xY wddd� � �d{V �� n# 1 �d{V ��swxY w Y | j � � � s?| j � � � | j � d{V �� dS # t j $ r Y dS w xY wdS # | j � � � s=| j � � � | j � d{V �� w # t j $ r Y w w xY ww xY w)zV
Waits for the application to stop itself and returns any exceptions.
N)�
async_timeoutr �resultr �CancelledError�done�cancel)r r s r �waitz ApplicationCommunicator.wait s � � � �
�$�W�-�-�
�
�
�
�
�
�
�
�� �+�%�%�%�%�%�%�%��K�&�&�(�(�(�(�� �-� � � ��D�����
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
�
����
�
�
�
� �;�#�#�%�%�
�� �"�"�$�$�$�� �+�%�%�%�%�%�%�%�%�%�� �-� � � ��D�D�����
�
��4�;�#�#�%�%�
�� �"�"�$�$�$�� �+�%�%�%�%�%�%�%�%�� �-� � � ��D�����
���s� �C �A)�&A�A)�A�A)�A�A)�C �)
A3�3C �6A3�7C �-
B< �<C�C�3D,�
D�D,�D(�%D,�'D(�(D,Tc � � | j � � � s| j � � � d S |r| j � � � d S d S r )r r r r )r �
exceptionss r �stopz ApplicationCommunicator.stop* s^ � ��{� � �!�!� !� �K� � � � � � � �
� !� �K� � � � � � � � !� !r c �V � | � d�� � d S # t $ r Y d S w xY w)NF)r )r! � RuntimeError)r s r �__del__z ApplicationCommunicator.__del__1 sC � � � �I�I��I� '� '� '� '� '��� � � � �D�D� ���s � �
(�(c � �J K � | j � |� � � d{V �� dS )z;
Sends a single message to the application
N)r r )r �messages r �
send_inputz"ApplicationCommunicator.send_input9 s7 � � � �
� �"�"�7�+�+�+�+�+�+�+�+�+�+�+r c � �2 K � | j � � � r| j � � � t |� � 4 �d{V �� | j � � � � d{V ��cddd� � �d{V �� S # 1 �d{V ��swxY w Y dS # t j $ rw}| j � � � r| j � � � n=| j � � � | j � d{V �� n# t j $ r Y nw xY w|�d}~ww xY w)zX
Receives a single message from the application, with optional timeout.
N)
r r r r r r r � TimeoutErrorr r )r r �es r �receive_outputz&ApplicationCommunicator.receive_output@ s� � � � �
�;� � � � � !� �K� � � � � �
�$�W�-�-�
5�
5�
5�
5�
5�
5�
5�
5� !� .� 2� 2� 4� 4�4�4�4�4�4�4�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5�
5����
5�
5�
5�
5�
5�
5���#�
�
�
��{� � �!�!�
�� �"�"�$�$�$�$�� �"�"�$�$�$�� �+�%�%�%�%�%�%�%�%�� �-� � � ��D������G�����
���s` �B � A=�*B �=
B�B �
B� B �D� A D�,
C:�9D�:D � D� D � D�D皙�����?�{�G�z�?c � �0 K � t j � � }t j � � |z
|k rO| j � � � sdS t j |� � � d{V �� t j � � |z
|k �O| j � � � S )zO
Checks that there is no message to receive in the given time.
FN)�time� monotonicr �emptyr �sleep)r r �interval�starts r �receive_nothingz'ApplicationCommunicator.receive_nothingW s� � � � �
�� � ���n� � ��&��0�0��$�*�*�,�,�
� �u��-��)�)� )� )� )� )� )� )� )� �n� � ��&��0�0� � �&�&�(�(�(r N)r )T)r, r- ) �__name__�
__module__� __qualname__�__doc__r r r! r$ r' r+ r5 � r r r r s� � � � � � �� �
�
�
�� � � �&!� !� !� !�� � �,� ,� ,�� � � �.
)�
)�
)�
)�
)�
)r r )r r/ �
compatibilityr r r r r: r r �<module>r< sw �� ���� � � � � 4� 4� 4� 4� 4� 4� -� -� -� -� -� -�Y)� Y)� Y)� Y)� Y)� Y)� Y)� Y)� Y)� Y)r