o
    óT·jµ  ã                   @  s�   d dl mZ d dlZd dlZd dlZeeeef eeeeeB f B eeedef B Z	G dd„ dƒZ
G dd„ dƒZG dd„ dƒZG d	d
„ d
ƒZdS )é    )ÚannotationsNc                   @  óH   e Zd Zdddd	„Zdddd„Zddd„Z		dd dd„Zd!dd„ZdS )"ÚNetworkStreamNÚ	max_bytesÚintÚtimeoutúfloat | NoneÚreturnÚbytesc                 C  ó   t ƒ ‚©N©ÚNotImplementedError©Úselfr   r   © r   ú[/home/dinkstrade/pdmp-scanner/venv/lib/python3.10/site-packages/httpcore2/_backends/base.pyÚread   ó   zNetworkStream.readÚbufferÚNonec                 C  r   r   r   ©r   r   r   r   r   r   Úwrite   r   zNetworkStream.writec                 C  r   r   r   ©r   r   r   r   Úclose   r   zNetworkStream.closeÚssl_contextússl.SSLContextÚserver_hostnameú
str | Nonec                 C  r   r   r   ©r   r   r   r   r   r   r   Ú	start_tls   ó   zNetworkStream.start_tlsÚinfoÚstrú
typing.Anyc                 C  ó   d S r   r   ©r   r"   r   r   r   Úget_extra_info   ó   zNetworkStream.get_extra_infor   ©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   c                   @  ó8   e Zd Z			dddd„Z		dddd„Zddd„ZdS )ÚNetworkBackendNÚhostr#   Úportr   r   r   Úlocal_addressr   Úsocket_optionsú%typing.Iterable[SOCKET_OPTION] | Noner	   r   c                 C  r   r   r   ©r   r4   r5   r   r6   r7   r   r   r   Úconnect_tcp!   s   zNetworkBackend.connect_tcpÚpathc                 C  r   r   r   ©r   r;   r   r7   r   r   r   Úconnect_unix_socket+   r!   z"NetworkBackend.connect_unix_socketÚsecondsÚfloatr   c                 C  s   t  |¡ d S r   )ÚtimeÚsleep©r   r>   r   r   r   rA   3   s   zNetworkBackend.sleep©NNN)r4   r#   r5   r   r   r   r6   r   r7   r8   r	   r   r,   )r;   r#   r   r   r7   r8   r	   r   ©r>   r?   r	   r   ©r.   r/   r0   r:   r=   rA   r   r   r   r   r3       ó    úür3   c                   @  r   )"ÚAsyncNetworkStreamNr   r   r   r   r	   r
   c                 Ã  ó   �t ƒ ‚r   r   r   r   r   r   r   8   ó   €zAsyncNetworkStream.readr   r   c                 Ã  rH   r   r   r   r   r   r   r   ;   rI   zAsyncNetworkStream.writec                 Ã  rH   r   r   r   r   r   r   Úaclose>   rI   zAsyncNetworkStream.acloser   r   r   r   c                 Ã  rH   r   r   r   r   r   r   r    A   ó   €zAsyncNetworkStream.start_tlsr"   r#   r$   c                 C  r%   r   r   r&   r   r   r   r'   I   r(   z!AsyncNetworkStream.get_extra_infor   r)   r*   r+   r,   )r   r   r   r   r   r   r	   rG   r-   )r.   r/   r0   r   r   rJ   r    r'   r   r   r   r   rG   7   r1   rG   c                   @  r2   )ÚAsyncNetworkBackendNr4   r#   r5   r   r   r   r6   r   r7   r8   r	   rG   c                 Ã  rH   r   r   r9   r   r   r   r:   N   s   €zAsyncNetworkBackend.connect_tcpr;   c                 Ã  rH   r   r   r<   r   r   r   r=   X   rK   z'AsyncNetworkBackend.connect_unix_socketr>   r?   r   c                 Ã  rH   r   r   rB   r   r   r   rA   `   rI   zAsyncNetworkBackend.sleeprC   )r4   r#   r5   r   r   r   r6   r   r7   r8   r	   rG   r,   )r;   r#   r   r   r7   r8   r	   rG   rD   rE   r   r   r   r   rL   M   rF   rL   )Ú
__future__r   Ússlr@   ÚtypingÚtupler   r
   Ú	bytearrayÚSOCKET_OPTIONr   r3   rG   rL   r   r   r   r   Ú<module>   s    0