Method run

example/E03-ThirdFlow.cpp:83–98

class ResultGNode : public GNode {
public:
    CStatus run() override {
        while (true) {
            std::shared_ptr<ResultMParam> result = nullptr;
            auto status = CGRAPH_RECV_MPARAM_WITH_TIMEOUT(ResultMParam, RESULT_TOPIC_NAME, result, 1000);
            if (status.isErr()) {
                break;
            }

            randomSleep(1, 5);
            CGRAPH_ECHO("negative num is [%d], english info is [%s], process time is [%d]ms",
                        result->negative_num_, result->eng_info_.c_str(), result->process_ts_);
        }

        CGRAPH_ECHO("    ----> ResultGNode run finished");
        return CStatus();
    }
};

void example_third_flow() {