Method Invoke

src/interface/aimrt_module_cpp_interface/rpc/rpc_handle.h:327–356

 protected:
  template <class ReqType, class RspType>
  aimrt::rpc::Status Invoke(
      std::string_view full_func_name,
      aimrt::rpc::ContextRef ctx_ref,
      const ReqType& req,
      RspType& rsp) {
    std::promise<aimrt::rpc::Status> result_promise;

    if (ctx_ref) {
      ctx_ref.SetFunctionName(full_func_name);

      rpc_handle_ref_.Invoke(
          full_func_name, ctx_ref, &req, &rsp,
          [&result_promise](uint32_t code) {
            result_promise.set_value(aimrt::rpc::Status(code));
          });

      return result_promise.get_future().get();
    }

    auto ctx_ptr = NewContextSharedPtr();
    ctx_ptr->SetFunctionName(full_func_name);

    rpc_handle_ref_.Invoke(
        full_func_name, *ctx_ptr, &req, &rsp,
        [&result_promise](uint32_t code) {
          result_promise.set_value(aimrt::rpc::Status(code));
        });

    return result_promise.get_future().get();
  }
};

class AsyncProxyBase : public ProxyBase {