def _read_body(self, size):
        body = SocketError.wrap(self._socket_file.read, size)
        SocketError.wrap(self._socket_file.read, 2)  # trailing crlf
        if size > 0 and not body:
            raise SocketError()
        return body
dataset/ETHPy150Open chexov/queueit/beanstalkd/queueit/beanstalkc.py/Connection._read_body/original