From 92d8c0d71a2948bc1fc3eef937d05a360f03399f Mon Sep 17 00:00:00 2001 From: Vladimir Komendantskiy Date: Tue, 24 Apr 2018 11:39:40 +0100 Subject: [PATCH] fold was not using the variable capturing the sequential data; I fixed that --- src/messaging.rs | 7 +------ tests/broadcast.rs | 2 +- 2 files changed, 2 insertions(+), 7 deletions(-) diff --git a/src/messaging.rs b/src/messaging.rs index f9ce40d..60728f2 100644 --- a/src/messaging.rs +++ b/src/messaging.rs @@ -284,12 +284,7 @@ impl<'a, HandlerError: AlgoError> MessageLoop<'a, HandlerError> { } => { self.remote_txs.iter().fold(result, |result1, (uid, tx)| { if result1.is_err() { result1 } else { - if let Some(tx) = self.remote_txs.get(&uid) { - tx.send(message.clone()).map_err(Error::from) - } - else { - Err(Error::SendError) - } + tx.send(message.clone()).map_err(Error::from) } }) } diff --git a/tests/broadcast.rs b/tests/broadcast.rs index aeac225..27fbe99 100644 --- a/tests/broadcast.rs +++ b/tests/broadcast.rs @@ -68,7 +68,7 @@ impl<'a> TestNode<'a> pub fn run(&'a self) -> Result, Error> { - let node0_uid = "127.0.0.1:0".parse().unwrap(); + let node0_uid = node_addr(0); self.message_loop.insert_algo(Algorithm::Broadcast(node0_uid), self); Err(Error::NotImplemented)