
    i                     `    d dl mZ  G d d      Z G d d      Z G d d      Z G d d	      Zy
)    )Optionalc                       e Zd ZddZy)SyncResolverc                     t               NNotImplementedErrorselfhostportfamilys       D/root/searxng-venv/lib/python3.12/site-packages/python_socks/_abc.pyresolvezSyncResolver.resolve       !##    Nr   r   __name__
__module____qualname__r    r   r   r   r          $r   r   c                       e Zd ZddZy)AsyncResolverc                    K   t               wr   r   r
   s       r   r   zAsyncResolver.resolve
        !##   Nr   r   r   r   r   r   r   	   r   r   r   c                   >    e Zd ZdefdZd	dee   fdZdefdZd Z	y)
SyncSocketStreamdatac                     t               r   r   r   r!   s     r   	write_allzSyncSocketStream.write_all   r   r   N	max_bytesc                     t               r   r   r   r%   s     r   readzSyncSocketStream.read   r   r   nc                     t               r   r   r   r)   s     r   
read_exactzSyncSocketStream.read_exact   r   r   c                     t               r   r   r   s    r   closezSyncSocketStream.close   r   r   r   
r   r   r   bytesr$   r   intr(   r,   r/   r   r   r   r    r       s/    $e $$hsm $$C $$r   r    c                   >    e Zd ZdefdZd	dee   fdZdefdZd Z	y)
AsyncSocketStreamr!   c                    K   t               wr   r   r#   s     r   r$   zAsyncSocketStream.write_all   r   r   Nr%   c                    K   t               wr   r   r'   s     r   r(   zAsyncSocketStream.read!   r   r   r)   c                    K   t               wr   r   r+   s     r   r,   zAsyncSocketStream.read_exact$   r   r   c                    K   t               wr   r   r.   s    r   r/   zAsyncSocketStream.close'   r   r   r   r0   r   r   r   r4   r4      s/    $E $$HSM $$# $$r   r4   N)typingr   r   r   r    r4   r   r   r   <module>r:      s0    $ $
$ $
$ $$ $r   