
    i                     z    d dl mZ  G d d          Z G d d          Z G d d          Z G d d	          Zd
S )    )Optionalc                       e Zd ZddZdS )SyncResolverr   c                     t                      NNotImplementedErrorselfhostportfamilys       X/home/ubuntu/.hermes/hermes-agent/venv/lib/python3.11/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dS )AsyncResolverr   c                 "   K   t                      r   r   r
   s       r   r   zAsyncResolver.resolve
         !###r   Nr   r   r   r   r   r   r   	   r   r   r   c                   F    e Zd ZdefdZd	dee         fdZdefdZd Z	dS )
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                   F    e Zd ZdefdZd	dee         fdZdefdZd Z	dS )
AsyncSocketStreamr    c                 "   K   t                      r   r   r"   s     r   r#   zAsyncSocketStream.write_all   r   r   Nr$   c                 "   K   t                      r   r   r&   s     r   r'   zAsyncSocketStream.read!   r   r   r(   c                 "   K   t                      r   r   r*   s     r   r+   zAsyncSocketStream.read_exact$   r   r   c                 "   K   t                      r   r   r-   s    r   r.   zAsyncSocketStream.close'   r   r   r   r/   r   r   r   r3   r3      s}        $E $ $ $ $$ $HSM $ $ $ $$# $ $ $ $$ $ $ $ $r   r3   N)typingr   r   r   r   r3   r   r   r   <module>r9      s         $ $ $ $ $ $ $ $
$ $ $ $ $ $ $ $
$ $ $ $ $ $ $ $$ $ $ $ $ $ $ $ $ $r   