U †´wi+ã@s:ddlZddlmZddlmZdZGdd„dejƒZdS)éNé)Ú ProxyError)Ú_abcic@sLeZdZUejed<ejdœdd„Zdd„Zefdd„Zd d „Z d d „Z d S)ÚSyncSocketStreamÚ_socket)ÚsockcCs ||_dS©N)r)Úselfr©r ú=/tmp/pip-unpacked-wheel-kpmwgv_b/python_socks/sync/_stream.pyÚ__init__ szSyncSocketStream.__init__cCs|j |¡dSr)rÚsendall)r Údatar r r Ú write_allszSyncSocketStream.write_allcCs |j |¡Sr)rÚrecv)r Z max_bytesr r r ÚreadszSyncSocketStream.readcCs@tƒ}t|ƒ|kr<|j |t|ƒ¡}|s2tdƒ‚||7}q|S)NzConnection closed unexpectedly)Ú bytearrayÚlenrrr)r ÚnrÚpacketr r r Ú read_exacts  zSyncSocketStream.read_exactcCs|jdk r|j ¡dSr)rÚclose)r r r r rs zSyncSocketStream.closeN) Ú__name__Ú __module__Ú __qualname__ÚsocketÚ__annotations__r rÚDEFAULT_RECEIVE_SIZErrrr r r r r s    r)rÚ_errorsrÚrÚabcrrr r r r Ús