← back to Atmos Game
assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/__pycache__/mock.cpython-312.pyc
35 lines
�
c�bj� � � � d dl mZ d dlZd dlZddlmZ ddlmZmZm Z m
Z
m Z G d� d� Z G d � d
e � Z
G d � d e
� Z G d
� de � Z G d� de� Zy)� )� annotationsN� )� ReadError� )�
SOCKET_OPTION�AsyncNetworkBackend�AsyncNetworkStream�NetworkBackend�
NetworkStreamc � � e Zd Zdd�Zdd�Zy)�
MockSSLObjectc � � || _ y �N��_http2)�self�http2s �n/Users/macstudio3/Projects/atmos-game/assets/gen/.venv/lib/python3.12/site-packages/httpcore/_backends/mock.py�__init__zMockSSLObject.__init__ s � ��� � c �" � | j rdS dS )N�h2zhttp/1.1r �r s r �selected_alpn_protocolz$MockSSLObject.selected_alpn_protocol s � ��{�{�t�2�
�2r N)r �bool��return�str)�__name__�
__module__� __qualname__r r � r r r
r
s � � �3r r
c �^ � e Zd Zd d
d�Zd d d�Zd d
d�Zdd�Z d dd�Zdd�Zdd�Z y)�
MockStreamc �. � || _ || _ d| _ y �NF��_bufferr �_closed�r �bufferr s r r zMockStream.__init__ � � � �� ��� � �� r Nc � � | j r t d� �| j sy| j j d� S �NzConnection closedr r �r) r r( �pop�r � max_bytes�timeouts r �readzMockStream.read s4 � � �<�<�� /�0� 0��|�|���|�|� � ��"�"r c � � y r r" �r r+ r3 s r �writezMockStream.write% � � � r c � � d| _ y �NT�r) r s r �closezMockStream.close( s � ��� r c � � | S r r" �r � ssl_context�server_hostnamer3 s r � start_tlszMockStream.start_tls+ s � � � r c �< � |dk( rt | j �� S d S �N�
ssl_object�r �r
r �r �infos r �get_extra_infozMockStream.get_extra_info3 � � �37�<�3G�}�4�;�;�/�Q�T�Qr c � � y)Nz<httpcore.MockStream>r" r s r �__repr__zMockStream.__repr__6 s � �&r �F�r+ z list[bytes]r r r �Noner �r2 �intr3 � float | Noner �bytes�r+ rS r3 rR r rO �r rO �NN)r? �ssl.SSLContextr@ �
str | Noner3 rR r r �rH r r z
typing.Anyr )
r r r! r r4 r7 r< rA rI rL r" r r r$ r$ sT � � �
#�
� � '+� $� �#�� $�� � �
� �R�'r r$ c �` � e Zd Zddd�Z d d d�Z d
d d�Zd d�Zy)
� MockBackendc � � || _ || _ y r �r( r r* s r r zMockBackend.__init__; � � � �� ��� r Nc �V � t t | j � | j �� S �NrE �r$ �listr( r �r �host�portr3 �
local_address�socket_optionss r � connect_tcpzMockBackend.connect_tcp? s � � �$�t�|�|�,�D�K�K�@�@r c �V � t t | j � | j �� S r` ra �r �pathr3 rg s r �connect_unix_socketz MockBackend.connect_unix_socketI s � � �$�t�|�|�,�D�K�K�@�@r c � � y r r" �r �secondss r �sleepzMockBackend.sleepQ r8 r rM rN �NNN) rd r re rQ r3 rR rf rX rg �%typing.Iterable[SOCKET_OPTION] | Noner r rV )rk r r3 rR rg rr r r �ro �floatr rO �r r r! r rh rl rp r" r r r[ r[ : s� � � � !%�$(�@D�
A��A� �A� � A�
"� A� >�
A�
�A� !%�@D� A��A� �A� >� A�
� A�
r r[ c �^ � e Zd Zd d
d�Zd d d�Zd d
d�Zdd�Z d dd�Zdd�Zdd�Z y)�AsyncMockStreamc �. � || _ || _ d| _ y r& r' r* s r r zAsyncMockStream.__init__V r, r Nc � � K � | j r t d� �| j sy| j j d� S �wr. r/ r1 s r r4 zAsyncMockStream.read[ s8 � �� � �<�<�� /�0� 0��|�|���|�|� � ��"�"�s �A Ac � � K � y �wr r" r6 s r r7 zAsyncMockStream.writeb � � �� � �� �c � � K � d| _ y �wr: r; r s r �aclosezAsyncMockStream.aclosee s
� �� ��� �s � c � � K � | S �wr r" r> s r rA zAsyncMockStream.start_tlsh s
� �� � � �s �c �< � |dk( rt | j �� S d S rC rF rG s r rI z AsyncMockStream.get_extra_infop rJ r c � � y)Nz<httpcore.AsyncMockStream>r" r s r rL zAsyncMockStream.__repr__s s � �+r rM rN r rP rT rU rV )r? rW r@ rX r3 rR r r rY r )
r r r! r r4 r7 r~ rA rI rL r" r r rw rw U sT � � �
#�
� � '+� $� �#�� $�� � �
� �R�,r rw c �` � e Zd Zddd�Z d d d�Z d
d d�Zd d�Zy)
�AsyncMockBackendc � � || _ || _ y r r] r* s r r zAsyncMockBackend.__init__x r^ r Nc � �^ K � t t | j � | j �� S �wr` �rw rb r( r rc s r rh z AsyncMockBackend.connect_tcp| s" � �� � �t�D�L�L� 1����E�E�� �+-c � �^ K � t t | j � | j �� S �wr` r� rj s r rl z$AsyncMockBackend.connect_unix_socket� s" � �� � �t�D�L�L� 1����E�E�r� c � � K � y �wr r" rn s r rp zAsyncMockBackend.sleep� r{ r| rM rN rq ) rd r re rQ r3 rR rf rX rg rr r r rV )rk r r3 rR rg rr r r rs ru r" r r r� r� w s� � � � !%�$(�@D�
F��F� �F� � F�
"� F� >�
F�
�F� !%�@D� F��F� �F� >� F�
� F�
r r� )�
__future__r �ssl�typing� _exceptionsr �baser r r r
r r
r$ r[ rw r� r" r r �<module>r� sY �� "�
�
� #�� �3� 3� '� � '�D
�.�
�6 ,�(� ,�D
�*�
r