← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/__pycache__/base.cpython-312.pyc
35 lines
�
c�bj� � � � d dl mZ d dlZd dlZd dlZej
ej eeef ej eeej
ee f f ej eedef f Z
G d� d� Z G d� d� Z G d� d� Z
G d � d
� Zy) � )� annotationsNc �L � e Zd Zddd�Zdd d�Zd
d�Z d d d�Zd
d�Zy)�
NetworkStreamNc � � t � ��N��NotImplementedError��self� max_bytes�timeouts �n/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/base.py�readzNetworkStream.read � � �!�#�#� c � � t � �r r �r �bufferr
s r �writezNetworkStream.write r r c � � t � �r r �r s r �closezNetworkStream.close r r c � � t � �r r �r � ssl_context�server_hostnamer
s r � start_tlszNetworkStream.start_tls �
� � "�#�#r c � � y r � �r �infos r �get_extra_infoz NetworkStream.get_extra_info � � �r r �r �intr
� float | None�return�bytes�r r) r
r' r( �None�r( r+ �NN)r �ssl.SSLContextr �
str | Noner
r' r( r �r" �strr( z
typing.Any)�__name__�
__module__� __qualname__r r r r r# r r r r r sI � �$�$�$� '+� $� $�#�$� $�$� � $�
� $�r r c �V � e Zd Z d dd�Z d dd�Zd d�Zy)
�NetworkBackendNc � � t � �r r �r �host�portr
�
local_address�socket_optionss r � connect_tcpzNetworkBackend.connect_tcp% s
� � "�#�#r c � � t � �r r �r �pathr
r< s r �connect_unix_socketz"NetworkBackend.connect_unix_socket/ r r c �. � t j |� y r )�time�sleep�r �secondss r rD zNetworkBackend.sleep7 s � � �
�
�7�r �NNN) r9 r1 r: r& r
r' r; r/ r< �%typing.Iterable[SOCKET_OPTION] | Noner( r r- )r@ r1 r
r' r< rH r( r �rF �floatr( r+ �r2 r3 r4 r= rA rD r r r r6 r6 $ s� � �
!%�$(�@D�
$��$� �$� � $�
"� $� >�
$�
�$� !%�@D� $��$� �$� >� $�
� $� r r6 c �L � e Zd Zddd�Zdd d�Zd
d�Z d d d�Zd
d�Zy)�AsyncNetworkStreamNc � � K � t � ��wr r r
s r r zAsyncNetworkStream.read< � � �� �!�#�#�� �
c � � K � t � ��wr r r s r r zAsyncNetworkStream.write? rO rP c � � K � t � ��wr r r s r �aclosezAsyncNetworkStream.acloseB rO rP c � � K � t � ��wr r r s r r z AsyncNetworkStream.start_tlsE � � �� � "�#�#�rP c � � y r r r! s r r# z!AsyncNetworkStream.get_extra_infoM r$ r r r% r* r, r- )r r. r r/ r
r' r( rM r0 )r2 r3 r4 r r rS r r# r r r rM rM ; sI � �$�$�$� '+� $� $�#�$� $�$� � $�
� $�r rM c �V � e Zd Z d dd�Z d dd�Zd d�Zy)
�AsyncNetworkBackendNc � � K � t � ��wr r r8 s r r= z AsyncNetworkBackend.connect_tcpR s � �� � "�#�#�rP c � � K � t � ��wr r r? s r rA z'AsyncNetworkBackend.connect_unix_socket\ rU rP c � � K � t � ��wr r rE s r rD zAsyncNetworkBackend.sleepd rO rP rG ) r9 r1 r: r& r
r' r; r/ r< rH r( rM r- )r@ r1 r
r' r< rH r( rM rI rK r r r rX rX Q s� � �
!%�$(�@D�
$��$� �$� � $�
"� $� >�
$�
�$� !%�@D� $��$� �$� >� $�
� $�$r rX )�
__future__r �sslrC �typing�Union�Tupler& r) � bytearray�
SOCKET_OPTIONr r6 rM rX r r r �<module>rc s� �� "�
� �
�� � �
�L�L��c�3� � �
�L�L��c�6�<�<��y�(8�9�9�:�
�L�L��c�4��$�%�'��
�� �, � �.� �,$� $r