tether-utils insights does not need owned copy of Topics, just ref

RandomStudio · Dec 23, 2024 · b66e92b · b66e92b
1 parent 982ff85
commit b66e92b
Show file tree

Hide file tree

Showing 5 changed files with 5 additions and 5 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/utilities/tether-utils/Cargo.toml b/utilities/tether-utils/Cargo.toml
@@ -1,7 +1,7 @@
 [package]
 name = "tether-utils"
 description = "Utilities for Tether Systems"
-version = "0.11.1"
+version = "0.11.2"
 edition = "2021"
 license = "MIT"
 repository = "https://github.com/RandomStudio/tether"

diff --git a/utilities/tether-utils/examples/api.rs b/utilities/tether-utils/examples/api.rs
@@ -63,7 +63,7 @@ fn demo_topics() {
 
     loop {
         while let Some((topic, payload)) = tether_agent.check_messages() {
-            if insights.update(topic, payload) {
+            if insights.update(&topic, payload) {
                 println!("TOPICS: Insights update: \n{}", insights);
             }
         }

diff --git a/utilities/tether-utils/src/bin/tether/main.rs b/utilities/tether-utils/src/bin/tether/main.rs
@@ -107,7 +107,7 @@ fn main() {
                     std::thread::sleep(Duration::from_millis(1));
                 }
                 while let Some((topic, payload)) = tether_agent.check_messages() {
-                    let topics_did_udate = insights.update(topic, payload);
+                    let topics_did_udate = insights.update(&topic, payload);
                     print_insights_summary(&insights, topics_did_udate, options.graph_enable);
                 }
                 if let Ok(elapsed) = last_update.elapsed() {

diff --git a/utilities/tether-utils/src/tether_topics/insights.rs b/utilities/tether-utils/src/tether_topics/insights.rs
@@ -69,7 +69,7 @@ impl Insights {
         &self.sampler
     }
 
-    pub fn update(&mut self, topic: TetherOrCustomTopic, payload: Vec<u8>) -> bool {
+    pub fn update(&mut self, topic: &TetherOrCustomTopic, payload: Vec<u8>) -> bool {
         self.message_count += 1;
 
         if self.log_start.is_none() {