
    i                     N    d dl mZ ddlmZmZ ddlmZ ddlmZ  G d de      Z	y	)
    )Optional   )AsyncSocketStreamAsyncResolver   )AsyncConnector)httpc                   X    e Zd Zdee   dee   defdZdededede	j                  fd	Zy
)HttpAsyncConnectorusernamepasswordresolverc                 .    || _         || _        || _        y )N)	_username	_password	_resolver)selfr   r   r   s       V/root/searxng-venv/lib/python3.12/site-packages/python_socks/_connectors/http_async.py__init__zHttpAsyncConnector.__init__	   s     "!!    streamhostportreturnc                 >  K   t        j                         }t        j                  ||| j                  | j                        }|j                  |      }|j                  |       d {    |j                          d {   }|j                  |      }|S 7 /7 w)N)r   r   r   r   )	r	   
ConnectionConnectRequestr   r   send	write_allreadreceive)r   r   r   r   connrequestdatareplys           r   connectzHttpAsyncConnector.connect   s       %%^^^^	
 yy!t$$$[[]"#'<<#5	 	%"s$   A'B)B*BBBBN)__name__
__module____qualname__r   strr   r   r   intr	   ConnectReplyr&    r   r   r   r      s\    "3-" 3-"  	"!  	
 
		r   r   N)
typingr   _abcr   r   abcr   
_protocolsr	   r   r-   r   r   <module>r2      s     3   r   