diff --git a/src/client.rs b/src/client.rs index 9d87921..b2af730 100644 --- a/src/client.rs +++ b/src/client.rs @@ -222,12 +222,11 @@ impl Client { control::Request::UserListRequest => { self.handle_user_list_request() - } - /* - _ =>{ - error!("Unhandled control request: {:?}", request); - }, - */ + } /* + _ =>{ + error!("Unhandled control request: {:?}", request); + }, + */ } } diff --git a/src/proto/frame.rs b/src/proto/frame.rs index db4543e..0f23271 100644 --- a/src/proto/frame.rs +++ b/src/proto/frame.rs @@ -170,7 +170,9 @@ where pub async fn read(&mut self) -> io::Result { loop { - if let Some(frame) = self.decoder.decode_from(&mut self.read_buffer)? { + if let Some(frame) = + self.decoder.decode_from(&mut self.read_buffer)? + { return Ok(frame); } self.stream.read_buf(&mut self.read_buffer).await?; @@ -188,7 +190,7 @@ mod tests { use bytes::BytesMut; use tokio::net::{TcpListener, TcpStream}; - use super::{FrameStream, FrameDecoder, FrameEncoder}; + use super::{FrameDecoder, FrameEncoder, FrameStream}; // Test value: [1, 3, 3, 7] in little-endian. const U32_1337: u32 = 1 + (3 << 8) + (3 << 16) + (7 << 24);