Skip to content

Commit

Permalink
doc: code improvement TODO based on #311
Browse files Browse the repository at this point in the history
  • Loading branch information
Devdutt Shenoi committed Dec 10, 2023
1 parent 11aabde commit edbd036
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions uplink/src/base/serializer/mod.rs
Original file line number Diff line number Diff line change
Expand Up @@ -555,6 +555,8 @@ impl<C: MqttClient> Serializer<C> {
// indefinitely write to disk to not loose data.
let client = match o {
Ok(c) => c,
// TODO: while we have to transition into crash mode, it's better not to write any inflight packets onto disk.
// This can be achieved with the serializer shutdown mode introduced in bytebeamio/uplink#311
Err(MqttError::Send(Request::Publish(publish))) => break Ok(Status::EventLoopCrash(publish, last_publish_stream)),
Err(e) => unreachable!("Unexpected error: {}", e),
};
Expand Down

0 comments on commit edbd036

Please sign in to comment.