From fd0c9371045fef56301d50dac79dbe1fe8342ce0 Mon Sep 17 00:00:00 2001 From: Devdutt Shenoi Date: Mon, 14 Oct 2024 13:00:06 +0530 Subject: [PATCH] test: fix breaking --- uplink/tests/serializer.rs | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/uplink/tests/serializer.rs b/uplink/tests/serializer.rs index 0a171110..5aea6ef0 100644 --- a/uplink/tests/serializer.rs +++ b/uplink/tests/serializer.rs @@ -87,18 +87,18 @@ async fn preferential_send_on_network() { one.set_persistence(persistence_path(&config.persistence_path, "one"), 1).unwrap(); one.write(publish("topic/one".to_string(), 4)).unwrap(); one.write(publish("topic/one".to_string(), 5)).unwrap(); - one.flush().unwrap(); + one.flush(); let mut two = Storage::new("topic/two", 1024 * 1024); two.set_persistence(persistence_path(&config.persistence_path, "two"), 1).unwrap(); two.write(publish("topic/two".to_string(), 3)).unwrap(); - two.flush().unwrap(); + two.flush(); let mut top = Storage::new("topic/top", 1024 * 1024); top.set_persistence(persistence_path(&config.persistence_path, "top"), 1).unwrap(); top.write(publish("topic/top".to_string(), 1)).unwrap(); top.write(publish("topic/top".to_string(), 2)).unwrap(); - top.flush().unwrap(); + top.flush(); let config = Arc::new(config); let (data_tx, data_rx) = bounded(1);