Method RpcTask

src/examples/cpp/context/module/rpc_client_module/rpc_client_module.cc:52–78

}

aimrt::co::Task<void> RpcClientModule::RpcTask() {
  ctx_ptr_->LetMe();

  try {
    AIMRT_INFO("Start RPC loop.");

    while (ctx_ptr_->Running()) {
      aimrt::protocols::example::GetFooDataReq req;
      aimrt::protocols::example::GetFooDataRsp rsp;
      req.set_msg("hello world");
      auto status = co_await client_.GetFooData(req, rsp);
      if (status.OK()) {
        AIMRT_INFO("RPC call succeeded, response: {}", rsp.msg());
      } else {
        AIMRT_WARN("RPC call failed, status: {}", status.ToString());
      }

      co_await aimrt::co::ScheduleAfter(aimrt::co::AimRTScheduler(time_executor_), std::chrono::milliseconds(static_cast<uint32_t>(1000 / rpc_frq_)));
    }

    AIMRT_INFO("Exit RPC loop.");
  } catch (const std::exception& e) {
    AIMRT_ERROR("RpcTask failed: {}", e.what());
  }

  co_return;
}

void RpcClientModule::Shutdown() {
  try {