fix ci

Author: YuanYuYuan

ros-z/examples/z_pubsub_ros2dds.rs

@@ -29,7 +29,7 @@
 //! cargo run --example z_pubsub_ros2dds --features ros2dds -- --role listener --topic chatter
 //! ```
 
-use std::time::Duration;
+use std::{num::NonZeroUsize, time::Duration};
 
 use clap::Parser;
 use ros_z::{
@@ -100,6 +100,7 @@ async fn main() -> ros_z::Result<()> {
         1, // node_id
         "ros2dds_demo".to_string(),
         "/".to_string(),
+        "/".to_string(), // enclave
     );
 
     // Topic name - ros2dds uses simple format without leading slash in KE
@@ -116,7 +117,7 @@ async fn main() -> ros_z::Result<()> {
     let qos = QosProfile {
         reliability: QosReliability::Reliable,
         durability: QosDurability::Volatile,
-        history: QosHistory::KeepLast(10),
+        history: QosHistory::KeepLast(NonZeroUsize::new(10).unwrap()),
         ..Default::default()
     };
 

ros-z/examples/z_srvcli_ros2dds.rs

@@ -141,11 +141,11 @@ async fn run_server(ctx: ros_z::context::ZContext, args: &Args) -> ros_z::Result
         request_count += 1;
 
         // Check if we've reached the max requests
-        if let Some(max) = max_requests {
-            if request_count >= max {
-                println!("Handled {} requests, exiting.", request_count);
-                break;
-            }
+        if let Some(max) = max_requests
+            && request_count >= max
+        {
+            println!("Handled {} requests, exiting.", request_count);
+            break;
         }
     }