

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