From c2e2519654250684b051017e3990a1ef00903abe Mon Sep 17 00:00:00 2001 From: vilayat-ali Date: Mon, 20 Nov 2023 12:38:46 +0530 Subject: [PATCH] inflight persistence logic --- uplink/src/base/serializer/mod.rs | 1 - 1 file changed, 1 deletion(-) diff --git a/uplink/src/base/serializer/mod.rs b/uplink/src/base/serializer/mod.rs index 7d25eb53..848b0d71 100644 --- a/uplink/src/base/serializer/mod.rs +++ b/uplink/src/base/serializer/mod.rs @@ -537,7 +537,6 @@ impl Serializer { let mut inflight_file = File::open(&path)?; inflight_file.read_to_end(&mut buf)?; let mut buf = BytesMut::from(buf.as_slice()); - // parse into publishes while let Ok(publish) = read(&mut buf, self.config.mqtt.max_packet_size) { match publish { Packet::Publish(publish) => {