diff --git a/tarpc/src/protocol.rs b/tarpc/src/protocol.rs index fea4688..7bddb77 100644 --- a/tarpc/src/protocol.rs +++ b/tarpc/src/protocol.rs @@ -345,9 +345,7 @@ impl RpcFutures { fn complete_reply(&mut self, id: u64, reply: Reply) { if let Some(tx) = self.0.as_mut().unwrap().remove(&id) { - if let Err(e) = tx.send(reply) { - warn!("Client dropped receiver for id {} before receiving reply: {}", id, e); - } + tx.send(reply).unwrap(); } else { warn!("RpcFutures: expected sender for id {} but got None!", id); }