Method processDataAssembling

core/src/stream/agenui_streaming_content_parser.cpp:42–50

    }

    void StreamingContentParser::processDataAssembling(const std::string& data) {
        AGENUI_PERFORMANCE_LOG("stream_assembling_begin", "");
        AGENUI_LOG("%s", data.c_str());
        _extractor.appendData(data);
        auto results = _extractor.driveParser();
        dispatchParseResultsBatched(results);

        AGENUI_PERFORMANCE_LOG("stream_assembling_end", "");
    }

    void StreamingContentParser::processDataEnding() {
        AGENUI_LOG("processing end");