address code review comment

holochain · Oct 23, 2024 · c1c12dc · c1c12dc
1 parent 3f6fee5
commit c1c12dc
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 4 deletions.
diff --git a/scenarios/remote_signals/src/main.rs b/scenarios/remote_signals/src/main.rs
@@ -133,19 +133,25 @@ fn agent_behaviour(
         .execute_in_place(async move {
             let now = Timestamp::now();
 
+            let mut timeout_count = 0;
+
             pending_set.lock().unwrap().retain(|msg| {
                 if now.as_millis() - msg.requested_at().as_millis()
                     > response_timeout.as_millis() as i64
                 {
-                    reporter.add_custom(
-                        ReportMetric::new("remote_signal_timeout").with_field("value", 1),
-                    );
+                    timeout_count += 1;
                     false
                 } else {
                     true
                 }
             });
 
+            while timeout_count > 0 {
+                reporter
+                    .add_custom(ReportMetric::new("remote_signal_timeout").with_field("value", 1));
+                timeout_count -= 1;
+            }
+
             match next_remote_signal_peer {
                 None => {
                     // No more agents available to signal, get a new list.

diff --git a/zomes/remote_signal/coordinator/Cargo.toml b/zomes/remote_signal/coordinator/Cargo.toml
@@ -1,5 +1,5 @@
 [package]
-name = "remote_signals"
+name = "remote_signal"
 version = "0.1.0"
 edition = "2021"
 description = "A Holochain coordinator zome for remote signals"