def parse_next_message(self):
        parsed_message = None
        remainder = self.message_buffer
        message = ""
        if self.SERIALIZED_COMMAND_TERMINATOR in self.message_buffer:
            message, _, remainder = self.message_buffer.partition(
                    self.SERIALIZED_COMMAND_TERMINATOR)
            try:
                parsed_message = JsonFormatter.deserialize(message)
                if not isinstance(parsed_message, dict):
                    raise ValueError()
            except ValueError:
                pass
        self.message_buffer = remainder
        return parsed_message
dataset/ETHPy150Open openxc/openxc-python/openxc/formats/json.py/JsonStreamer.parse_next_message/original