Skip to content

Commit

Permalink
inflight persistence logic
Browse files Browse the repository at this point in the history
  • Loading branch information
Vilayat-Ali committed Nov 20, 2023
1 parent 22f8d6b commit 79f127c
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion uplink/src/base/serializer/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -537,7 +537,6 @@ impl<C: MqttClient> Serializer<C> {
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) => {
Expand Down

0 comments on commit 79f127c

Please sign in to comment.