diff --git a/p2p/src/conn.rs b/p2p/src/conn.rs index 81737f9c0..5e873bae2 100644 --- a/p2p/src/conn.rs +++ b/p2p/src/conn.rs @@ -202,7 +202,7 @@ impl Connection { /// Utility function to send any Writeable. Handles adding the header and /// serialization. - pub fn send_msg (&self, t: Type, body: &W) -> Result<(), Error> { + pub fn send_msg(&self, t: Type, body: &W) -> Result<(), Error> { let mut body_data = vec![]; try!(ser::serialize(&mut body_data, body)); @@ -283,11 +283,11 @@ impl TimeoutConnection { /// Sends a request and registers a timer on the provided message type and /// optionally the hash of the sent data. pub fn send_request(&self, - t: Type, - rt: Type, - body: &W, - expect_h: Option<(Hash)>) - -> Result<(), Error> { + t: Type, + rt: Type, + body: &W, + expect_h: Option<(Hash)>) + -> Result<(), Error> { let sent = try!(self.underlying.send_msg(t, body)); let mut expects = self.expected_responses.lock().unwrap(); diff --git a/p2p/src/protocol.rs b/p2p/src/protocol.rs index 1323cd6bb..d7aebcc3f 100644 --- a/p2p/src/protocol.rs +++ b/p2p/src/protocol.rs @@ -111,11 +111,11 @@ impl ProtocolV1 { } fn send_request(&self, - t: Type, - rt: Type, - body: &W, - expect_resp: Option) - -> Result<(), Error> { + t: Type, + rt: Type, + body: &W, + expect_resp: Option) + -> Result<(), Error> { self.conn.borrow().send_request(t, rt, body, expect_resp) } }