Cumulocity mapper using actors #1909

thin-edge · Apr 26, 2023 · 77b9c4e · 77b9c4e
1 parent f732ba3
commit 77b9c4e
Show file tree

Hide file tree

Showing 25 changed files with 1,214 additions and 1,888 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/crates/common/mqtt_channel/src/messages.rs b/crates/common/mqtt_channel/src/messages.rs
@@ -126,6 +126,16 @@ impl From<Publish> for Message {
     }
 }
 
+impl<T, U> From<(T, U)> for Message
+where
+    T: AsRef<str>,
+    U: AsRef<str>,
+{
+    fn from(value: (T, U)) -> Self {
+        Message::new(&Topic::new_unchecked(value.0.as_ref()), value.1.as_ref())
+    }
+}
+
 #[cfg(test)]
 mod tests {
     use super::*;