Ë
    øÙòiW  ã                   óZ   — d dl Zd dlZddlmZ ddlmZ dZ G d„ dej                  «      Z
y)é    Né   )Ú_abc)Ú
ProxyErrori   c                   ó”   — e Zd ZU dZej
                  j                  ed<   dej
                  j                  fd„Zd„ Z	e
fd„Zd„ Zd„ Zy)	ÚCurioSocketStreamNÚ_socketÚsockc                 ó   — || _         y ©N)r   )Úselfr	   s     úT/root/searxng-venv/lib/python3.12/site-packages/python_socks/async_/curio/_stream.pyÚ__init__zCurioSocketStream.__init__   s	   € Øˆó    c              ƒ   óV   K  — | j                   j                  |«      ƒ d {  –—†  y 7 Œ­wr   )r   Úsendall)r   Údatas     r   Ú	write_allzCurioSocketStream.write_all   s   è ø€ Øl‰l×"Ñ" 4Ó(×(Ò(ús   ‚)¡'¢)c              ƒ   óT   K  — | j                   j                  |«      ƒ d {  –—† S 7 Œ­wr   )r   Úrecv)r   Ú	max_bytess     r   ÚreadzCurioSocketStream.read   s!   è ø€ Ø—\‘\×&Ñ& yÓ1×1Ð1Ð1ús   ‚(¡&¢(c              ƒ   óâ   K  — t        «       }t        |«      |k  rP| j                  j                  |t        |«      z
  «      ƒ d {  –—† }|st	        d«      ‚||z  }t        |«      |k  rŒP|S 7 Œ'­w)NzConnection closed unexpectedly)Ú	bytearrayÚlenr   r   r   )r   Únr   Úpackets       r   Ú
read_exactzCurioSocketStream.read_exact   sh   è ø€ Ü‹{ˆÜ$‹i˜!ŠmØŸ<™<×,Ñ,¨Q´°T³©]Ó;×;ˆFÙÜ Ð!AÓBÐBØF‰NˆDô	 $‹i˜!‹mð
 ˆð	 <ús   ‚AA/ÁA-Á$A/Á+A/c              ƒ   óT   K  — | j                   j                  «       ƒ d {  –—†  y 7 Œ­wr   )r   Úclose)r   s    r   r   zCurioSocketStream.close   s   è ø€ Øl‰l× Ñ Ó"×"Ò"ús   ‚( &¡()Ú__name__Ú
__module__Ú__qualname__r   ÚcurioÚioÚSocketÚ__annotations__r   r   ÚDEFAULT_RECEIVE_SIZEr   r   r   © r   r   r   r   
   sA   … Ø#€GˆUX‰X_‰_Ó#ð˜UŸX™XŸ_™_ó ò)ð $8ó 2òó#r   r   )Úcurio.ior#   Úcurio.socketÚ r   ÚabcÚ_errorsr   r'   ÚAsyncSocketStreamr   r(   r   r   ú<module>r/      s)   ðÛ Û å Ý !àÐ ô#˜×-Ñ-õ #r   