From 96d8f25d43a1b6009dd8124a49dc8ba8b48fe996 Mon Sep 17 00:00:00 2001
From: WILLIAMS Harvey <hwilliam@inria.fr>
Date: Mon, 17 Mar 2025 14:19:01 +0100
Subject: [PATCH] Moved to iterator
---
examples/local/src/net/dispatch.rs | 9 +++++----
1 file changed, 5 insertions(+), 4 deletions(-)
diff --git a/examples/local/src/net/dispatch.rs b/examples/local/src/net/dispatch.rs
index 0f2d8f6..3f4f5af 100644
--- a/examples/local/src/net/dispatch.rs
+++ b/examples/local/src/net/dispatch.rs
@@ -82,11 +82,12 @@ impl Actor {
DispatchMessage::SendMessage { to, message} => {
// Look for senders to dispatch message to
if let Some(senders) = self.senders.get_mut(&to) {
- for sender in senders.iter_mut() {
- sender.try_send((to.clone(), message.clone())).expect("Expected sender channel to be closed and not full.")
- }
+ senders
+ .iter_mut()
+ .try_for_each(|sender| sender.try_send((to.clone(), message.clone())))
+ .expect("Expected sender channel to be open and not full");
} else {
- panic!("No sender with address {} to dispatch message to.", to);
+ eprintln!("No sender with address {} to dispatch - Message dropped.", to);
}
},
DispatchMessage::RegisterHandler { address, respond_to } => {
--
GitLab