i+PddlZddlmZddlmZdZGddejZdS)N) ProxyError)_abcicVeZdZUejed<dejfdZdZefdZdZ dZ dS) SyncSocketStream_socketsockc||_dSN)r)selfr s Z/usr/local/lib/hermes-agent/venv/lib/python3.11/site-packages/python_socks/sync/_stream.py__init__zSyncSocketStream.__init__ s  c:|j|dSr )rsendall)r datas r write_allzSyncSocketStream.write_alls T"""""rc6|j|Sr )rrecv)r max_bytess r readzSyncSocketStream.reads|  +++rct}t||krS|j|t|z }|st d||z }t||kS|S)NzConnection closed unexpectedly) bytearraylenrrr)r nrpackets r read_exactzSyncSocketStream.read_exactsr{{$ii!mm\&&q3t99}55F C !ABBB FND $ii!mm  rcJ|j|jdSdSr )rclose)r s r rzSyncSocketStream.closes, < # L    $ #rN) __name__ __module__ __qualname__socket__annotations__rrDEFAULT_RECEIVE_SIZErrrrr rr s ]V]###2,,,,!!!!!rr)r#_errorsrrabcr%rr&rr r*so !!!!!s+!!!!!r