Don't unwrap on schedule error in fragmentation test

eclipse-zenoh · Nov 7, 2024 · 694e3fa · 694e3fa
1 parent f4b4cad
commit 694e3fa
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/io/zenoh-transport/tests/unicast_fragmentation.rs b/io/zenoh-transport/tests/unicast_fragmentation.rs
@@ -290,13 +290,13 @@ async fn test_transport(router_handler: Arc<SHRouter>, client_transport: Transpo
     ztimeout!(async {
         let mut sent = 0;
         while router_handler.get_count() < MSG_COUNT {
-            client_transport.schedule(MSG.clone()).unwrap();
-            sent += 1;
-            println!(
-                "Sent: {sent}. Received: {}/{MSG_COUNT}",
-                router_handler.get_count()
-            );
-            // tokio::time::sleep(SLEEP_SEND).await;
+            if client_transport.schedule(MSG.clone()).is_ok() {
+                sent += 1;
+                println!(
+                    "Sent: {sent}. Received: {}/{MSG_COUNT}",
+                    router_handler.get_count()
+                );
+            }
         }
     });