diff --git a/tarpc/src/protocol.rs b/tarpc/src/protocol.rs index 21c9cab..2aeff12 100644 --- a/tarpc/src/protocol.rs +++ b/tarpc/src/protocol.rs @@ -444,9 +444,7 @@ impl Client let mut state = self.synced_state.lock().unwrap(); let id = increment(&mut state.next_id); { // block required to drop lock asap - if let Err(e) = self.requests.lock().unwrap().insert_tx(id, tx) { - return Err(e); - } + try!(self.requests.lock().unwrap().insert_tx(id, tx)); } let packet = Packet { rpc_id: id, @@ -461,9 +459,7 @@ impl Client warn!("Client: failed to write packet.\nPacket: {:?}\nError: {:?}", packet, err); - if let Err(e) = self.requests.lock().unwrap().remove_tx(id) { - return Err(e); - } + try!(self.requests.lock().unwrap().remove_tx(id)); } drop(state); match rx.recv() {