
    ]jg                    "   d dl mZ d dlZd dlZd dlZej        ej        eeef         ej        eeej        ee	f         f         ej        eedef         f         Z
 G d d          Z G d d          Z G d d          Z G d	 d
          ZdS )    )annotationsNc                  @    e Zd ZdddZdddZddZ	 	 dddZddZdS )NetworkStreamN	max_bytesinttimeoutfloat | Nonereturnbytesc                    t                      NNotImplementedErrorselfr   r   s      S/var/www/html/afkarena/venv/lib/python3.11/site-packages/httpcore/_backends/base.pyreadzNetworkStream.read       !###    bufferNonec                    t                      r   r   r   r   r   s      r   writezNetworkStream.write   r   r   c                    t                      r   r   r   s    r   closezNetworkStream.close   r   r   ssl_contextssl.SSLContextserver_hostname
str | Nonec                    t                      r   r   r   r   r    r   s       r   	start_tlszNetworkStream.start_tls        "###r   infostr
typing.Anyc                    d S r    r   r&   s     r   get_extra_infozNetworkStream.get_extra_info        tr   r   r   r   r   r	   r
   r   r   r   r   r	   r
   r   r
   r   NN)r   r   r    r!   r   r	   r
   r   r&   r'   r
   r(   )__name__
__module____qualname__r   r   r   r$   r,   r*   r   r   r   r              $ $ $ $ $$ $ $ $ $$ $ $ $ '+ $	$ $ $ $ $     r   r   c                  4    e Zd Z	 	 	 dddZ	 	 dddZddZdS )NetworkBackendNhostr'   portr   r   r	   local_addressr!   socket_options%typing.Iterable[SOCKET_OPTION] | Noner
   r   c                    t                      r   r   r   r9   r:   r   r;   r<   s         r   connect_tcpzNetworkBackend.connect_tcp%   s     "###r   pathc                    t                      r   r   r   rA   r   r<   s       r   connect_unix_socketz"NetworkBackend.connect_unix_socket/   r%   r   secondsfloatr   c                .    t          j        |           d S r   )timesleepr   rE   s     r   rI   zNetworkBackend.sleep7   s    
7r   NNN)r9   r'   r:   r   r   r	   r;   r!   r<   r=   r
   r   r1   )rA   r'   r   r	   r<   r=   r
   r   rE   rF   r
   r   r3   r4   r5   r@   rD   rI   r*   r   r   r8   r8   $   sm        
 !%$(@D$ $ $ $ $ !%@D	$ $ $ $ $     r   r8   c                  @    e Zd ZdddZdddZddZ	 	 dddZddZdS )AsyncNetworkStreamNr   r   r   r	   r
   r   c                "   K   t                      r   r   r   s      r   r   zAsyncNetworkStream.read<         !###r   r   r   c                "   K   t                      r   r   r   s      r   r   zAsyncNetworkStream.write?   rQ   r   c                "   K   t                      r   r   r   s    r   aclosezAsyncNetworkStream.acloseB   rQ   r   r   r   r    r!   c                "   K   t                      r   r   r#   s       r   r$   zAsyncNetworkStream.start_tlsE          "###r   r&   r'   r(   c                    d S r   r*   r+   s     r   r,   z!AsyncNetworkStream.get_extra_infoM   r-   r   r   r.   r/   r0   r1   )r   r   r    r!   r   r	   r
   rO   r2   )r3   r4   r5   r   r   rT   r$   r,   r*   r   r   rO   rO   ;   r6   r   rO   c                  4    e Zd Z	 	 	 dddZ	 	 dddZddZdS )AsyncNetworkBackendNr9   r'   r:   r   r   r	   r;   r!   r<   r=   r
   rO   c                "   K   t                      r   r   r?   s         r   r@   zAsyncNetworkBackend.connect_tcpR   s       "###r   rA   c                "   K   t                      r   r   rC   s       r   rD   z'AsyncNetworkBackend.connect_unix_socket\   rV   r   rE   rF   r   c                "   K   t                      r   r   rJ   s     r   rI   zAsyncNetworkBackend.sleepd   rQ   r   rK   )r9   r'   r:   r   r   r	   r;   r!   r<   r=   r
   rO   r1   )rA   r'   r   r	   r<   r=   r
   rO   rL   rM   r*   r   r   rY   rY   Q   sm        
 !%$(@D$ $ $ $ $ !%@D	$ $ $ $ $$ $ $ $ $ $r   rY   )
__future__r   sslrH   typingUnionTupler   r   	bytearraySOCKET_OPTIONr   r8   rO   rY   r*   r   r   <module>rd      s-   " " " " " " 



  
Lc3
Lc6<y(899:
Lc4$%'       ,       .       ,$ $ $ $ $ $ $ $ $ $r   