summaryrefslogtreecommitdiffstats
path: root/crates/core/tedge_mapper/src/az/converter.rs
diff options
context:
space:
mode:
Diffstat (limited to 'crates/core/tedge_mapper/src/az/converter.rs')
-rw-r--r--crates/core/tedge_mapper/src/az/converter.rs4
1 files changed, 2 insertions, 2 deletions
diff --git a/crates/core/tedge_mapper/src/az/converter.rs b/crates/core/tedge_mapper/src/az/converter.rs
index f7f4b7a9..b9da5b31 100644
--- a/crates/core/tedge_mapper/src/az/converter.rs
+++ b/crates/core/tedge_mapper/src/az/converter.rs
@@ -41,10 +41,10 @@ impl Converter for AzureConverter {
}
async fn try_convert(&mut self, input: &Message) -> Result<Vec<Message>, Self::Error> {
- let () = self.size_threshold.validate(input)?;
+ self.size_threshold.validate(input)?;
let default_timestamp = self.add_timestamp.then(|| self.clock.now());
let mut serializer = ThinEdgeJsonSerializer::new_with_timestamp(default_timestamp);
- let () = thin_edge_json::parser::parse_str(input.payload_str()?, &mut serializer)?;
+ thin_edge_json::parser::parse_str(input.payload_str()?, &mut serializer)?;
let payload = serializer.into_string()?;
Ok(vec![(Message::new(&self.mapper_config.out_topic, payload))])