← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/__pycache__/anyio.cpython-312.pyc
49 lines
�
c�bj� � � � d dl mZ d dlZd dlZd dlZddlmZmZmZm Z m
Z
m Z m Z ddl
mZ ddlmZmZmZ G d� d e� Z G d
� d e� Zy) � )� annotationsN� )� ConnectError�ConnectTimeout� ReadError� ReadTimeout�
WriteError� WriteTimeout�map_exceptions)�is_socket_readable� )�
SOCKET_OPTION�AsyncNetworkBackend�AsyncNetworkStreamc �T � e Zd Zdd�Zd d
d�Zd d d�Zd d�Z d
dd�Zdd�Zy)� AnyIOStreamc � � || _ y �N)�_stream)�self�streams �o/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/anyio.py�__init__zAnyIOStream.__init__ s � � �� � Nc � �� K � t t t j t t j
t t j t i}t |� 5 t j |� 5 | j j |�� � d { ��� cd d d � cd d d � S 7 �# t j $ r Y d d d � d d d � yw xY w# 1 sw Y nxY w d d d � y # 1 sw Y y xY w�w)N)� max_bytesr ) � TimeoutErrorr �anyio�BrokenResourceErrorr �ClosedResourceError� EndOfStreamr �
fail_afterr �receive)r r �timeout�exc_maps r �readzAnyIOStream.read s� � �� � �+� � %� %�y� � %� %�y� � � �y�
�� �G�
$��!�!�'�*� �!%� � �!5�!5� �!5�!J�J� +�*� %�
$� K�� �(�(� � � +� %�
$� �� +�*��*� %�
$�
$�sx �AC1�C%�,C�. B&�
B$�B&� C%�
C1�$B&�&C �9C�:C%� C1� C � C�C �C%� C1�%C.�*C1c � �Z K � |sy t t t j t t j
t i}t
|� 5 t j |� 5 | j j |�� � d { ��� d d d � d d d � y 7 �# 1 sw Y �xY w# 1 sw Y y xY w�w)N)�item)
r r
r r r r r r" r �send)r �bufferr$ r% s r �writezAnyIOStream.write' s� � �� �� �
�,� � %� %�z� � %� %�z�
��
�G�
$��!�!�'�*��l�l�'�'�V�'�4�4�4� +� %�
$�4�� +�*�� %�
$�sH �AB+�B � B�;B�<B� B � B+�B�B �B � B(�$B+c � �T K � | j j � � d { ��� y 7 ��wr )r �aclose)r s r r- zAnyIOStream.aclose4 s � �� ��l�l�!�!�#�#�#�s � (�&�(c � �J K � t t t j t t j
t t j t i}t |� 5 t j |� 5 t j j j j | j ||dd�� � d { ��� }d d d � d d d � t# � S 7 � # 1 sw Y � xY w# t $ r }| j! � � d { ���7 |�d }~ww xY w# 1 sw Y t# � S xY w�w)NF)� ssl_context�hostname�standard_compatible� server_side)r r r r r r! �ssl�SSLErrorr r" �streams�tls� TLSStream�wrapr � Exceptionr- r )r r/ �server_hostnamer$ r% �
ssl_stream�excs r � start_tlszAnyIOStream.start_tls7 s� � �� �
�.� � %� %�|� � � �|� �L�L�,�
�� �G�
$�
��%�%�g�.�',�}�}�'8�'8�'B�'B�'G�'G� � � �$/�!0�,1�$)� (H� (� "�J� /� %� �:�&�&�"�� /�.�� �
��k�k�m�#�#�� ��
�� %� �:�&�&�ss �AD#�D
�C!�-AC�3C�4C�8C!� D#�C�C �C!�! D
�*D�=D �>D�D
�
D
�
D �D#c �� � |dk( rH| j j t j j j
j d � S |dk( r>| j j t j j j d � S |dk( r>| j j t j j j d � S |dk( r>| j j t j j j d � S |dk( rI| j j t j j j d � }t |� S y )N�
ssl_object� client_addr� server_addr�socket� is_readable)
r �extrar r5 r6 � TLSAttributer? �abc�SocketAttribute�
local_address�remote_address�
raw_socketr )r �info�socks r �get_extra_infozAnyIOStream.get_extra_infoR s � � �<� ��<�<�%�%�e�m�m�&7�&7�&D�&D�&O�&O�QU�V� V� �=� ��<�<�%�%�e�i�i�&?�&?�&M�&M�t�T� T� �=� ��<�<�%�%�e�i�i�&?�&?�&N�&N�PT�U� U� �8� ��<�<�%�%�e�i�i�&?�&?�&J�&J�D�Q� Q� �=� ��<�<�%�%�e�i�i�&?�&?�&J�&J�D�Q�D�%�d�+� +�r )r zanyio.abc.ByteStream�return�Noner )r �intr$ � float | NonerN �bytes)r* rR r$ rQ rN rO )rN rO �NN)r/ zssl.SSLContextr: �
str | Noner$ rQ rN r )rK �strrN z
typing.Any) �__name__�
__module__� __qualname__r r& r+ r- r= rM � r r r r sN � � � � 5�$� '+� $� '�#�'� $�'� � '�
� '�6 r r c �V � e Zd Z d dd�Z d dd�Zd d�Zy)
� AnyIOBackendNc � � K � |�g }t t t t t j
t i}t
|� 5 t j |� 5 t j |||�� � d { ��� }|D ] } |j j |� � d d d � d d d � t � S 7 �@# 1 sw Y � xY w# 1 sw Y t � S xY w�w)N)� remote_host� remote_port�
local_host) r r �OSErrorr r r r r" � connect_tcp� _raw_socket�
setsockoptr ) r �host�portr$ rH �socket_optionsr% r �options r ra zAnyIOBackend.connect_tcpb s� � �� � � !� �N� �.� �\� � %� %�|�
��
�G�
$��!�!�'�*�5:�5F�5F� $� $� ,�6� 0�� -�F�1�F�&�&�1�1�6�:� -� +� %� �6�"�"�0�� +�*�� %� �6�"�"�sF �:C�B=� B1�.B/�/$B1�B=� C�/B1�1B: �6B=�=C�Cc � � K � |�g }t t t t t j
t i}t
|� 5 t j |� 5 t j |� � d { ��� }|D ] } |j j |� � d d d � d d d � t � S 7 �@# 1 sw Y � xY w# 1 sw Y t � S xY w�wr ) r r r` r r r r r" � connect_unixrb rc r )r �pathr$ rf r% r rg s r �connect_unix_socketz AnyIOBackend.connect_unix_socket} s� � �� � � !� �N� �.� �\� � %� %�|�
��
�G�
$��!�!�'�*�5:�5G�5G��5M�/M�� ,�F�1�F�&�&�1�1�6�:� -� +� %�
�6�"�"� 0N�� +�*�� %�
�6�"�"�sF �:C�B:�B.�+B,�,$B.�B:�C�,B.�.B7 �3B:�:C
�?Cc � �J K � t j |� � d { ��� y 7 ��wr )r �sleep)r �secondss r rm zAnyIOBackend.sleep� s � �� ��k�k�'�"�"�"�s �#�!�#)NNN) rd rU re rP r$ rQ rH rT rf �%typing.Iterable[SOCKET_OPTION] | NonerN r rS )rj rU r$ rQ rf ro rN r )rn �floatrN rO )rV rW rX ra rk rm rY r r r[ r[ a s� � �
!%�$(�@D�
#��#� �#� � #�
"� #� >�
#�
�#�< !%�@D� #��#� �#� >� #�
� #�(#r r[ )�
__future__r r3 �typingr � _exceptionsr r r r r r
r �_utilsr �baser r r r r[ rY r r �<module>rv sH �� "�
�
� �� � � (� H� H�I�$� I�X1#�&� 1#r