diff --git a/examples/local/src/net/dispatch.rs b/examples/local/src/net/dispatch.rs index 0f2d8f65957a646814066e4a679c8cbe417c85c7..3f4f5af7ec09c576628d0069f3df2bbe03ab3275 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 } => {