i+RddlZddlmZddlmZdZGddejZy)N) ProxyError)_abcicheZdZUejed<dejfdZdZefdZdZ dZ y) SyncSocketStream_socketsockc||_yN)r)selfr s L/root/searxng-venv/lib/python3.12/site-packages/python_socks/sync/_stream.py__init__zSyncSocketStream.__init__ s  c:|jj|yr )rsendall)r datas r write_allzSyncSocketStream.write_alls T"rc8|jj|Sr )rrecv)r max_bytess r readzSyncSocketStream.reads||  ++rct}t||krH|jj|t|z }|s t d||z }t||krH|S)NzConnection closed unexpectedly) bytearraylenrrr)r nrpackets r read_exactzSyncSocketStream.read_exacts\{$i!m\\&&q3t9}5F !ABB FND $i!m  rcR|j|jjyyr )rclose)r s r rzSyncSocketStream.closes! << # LL    $rN) __name__ __module__ __qualname__socket__annotations__rrDEFAULT_RECEIVE_SIZErrrrr rr s5 ]]V]]#2,!rr)r#_errorsrrabcr%rr&rr r*s& !s++!r