def _get_next_obj(self, length):
        """Assumes we've already read the object length"""
        data = b''
        while len(data) < length:
            data += self.sock.recv(length - len(data))

        return pickle.loads(data)