Ë
    VåÐi+  ã                   óR   — d dl Z ddlmZ ddlmZ dZ G d„ dej                  «      Zy)é    Né   )Ú
ProxyError)Ú_abci   c                   óh   — e Zd ZU ej                  ed<   dej                  fd„Zd„ Zefd„Zd„ Z	d„ Z
y)	ÚSyncSocketStreamÚ_socketÚsockc                 ó   — || _         y ©N)r   )Úselfr	   s     úQ/var/www/html/bot/venv1/lib/python3.12/site-packages/python_socks/sync/_stream.pyÚ__init__zSyncSocketStream.__init__   s	   € Øˆ�ó    c                 ó:   — | j                   j                  |«       y r   )r   Úsendall)r   Údatas     r   Ú	write_allzSyncSocketStream.write_all   s   € Ø�‰×Ñ˜TÕ"r   c                 ó8   — | j                   j                  |«      S r   )r   Úrecv)r   Ú	max_bytess     r   ÚreadzSyncSocketStream.read   s   € Ø�|‰|× Ñ  Ó+Ð+r   c                 óÆ   — t        «       }t        |«      |k  rH| j                  j                  |t        |«      z
  «      }|st	        d«      ‚||z  }t        |«      |k  rŒH|S )NzConnection closed unexpectedly)Ú	bytearrayÚlenr   r   r   )r   Únr   Úpackets       r   Ú
read_exactzSyncSocketStream.read_exact   s\   € Ü‹{ˆÜ�$‹i˜!ŠmØ—\‘\×&Ñ& q¬3¨t«9¡}Ó5ˆFÙÜ Ð!AÓBÐBØ�F‰NˆDô	 �$‹i˜!‹mð
 ˆr   c                 óR   — | j                   �| j                   j                  «        y y r   )r   Úclose)r   s    r   r   zSyncSocketStream.close   s!   € Ø�<‰<Ð#Ø�L‰L×ÑÕ ð $r   N)Ú__name__Ú
__module__Ú__qualname__ÚsocketÚ__annotations__r   r   ÚDEFAULT_RECEIVE_SIZEr   r   r   © r   r   r   r   	   s5   … Ø�]‰]Óð˜VŸ]™]ó ò#ð 2ó ,òó!r   r   )r#   Ú_errorsr   Ú r   Úabcr%   r   r&   r   r   ú<module>r*      s&   ðÛ å  Ý àÐ ô!�s×+Ñ+õ !r   