Merge pull request containerd#155 from Tim-Zhang/fix-clippy-warning-in-rust-1.63

clippy: fix warnings in rust 1.63

Author: Tim-Zhang

src/asynchronous/stream.rs

@@ -309,9 +309,11 @@ where
 }
 
 async fn _recv(rx: &mut ResultReceiver) -> Result<GenMessage> {
-    rx.recv()
-        .await
-        .unwrap_or_else(|| Err(Error::Others("Receive packet from recver error".to_string())))
+    rx.recv().await.unwrap_or_else(|| {
+        Err(Error::Others(
+            "Receive packet from recver error".to_string(),
+        ))
+    })
 }
 
 async fn _send(tx: &MessageSender, msg: GenMessage) -> Result<()> {
@@ -320,7 +322,7 @@ async fn _send(tx: &MessageSender, msg: GenMessage) -> Result<()> {
         .map_err(|e| Error::Others(format!("Send data packet to sender error {:?}", e)))
 }
 
-#[derive(Clone, Copy, Debug, PartialEq)]
+#[derive(Clone, Copy, Debug, PartialEq, Eq)]
 pub enum Kind {
     Client,
     Server,

src/proto.rs

@@ -28,7 +28,7 @@ pub const FLAG_REMOTE_OPEN: u8 = 0x2;
 pub const FLAG_NO_DATA: u8 = 0x4;
 
 /// Message header of ttrpc.
-#[derive(Default, Debug, Clone, Copy, PartialEq)]
+#[derive(Default, Debug, Clone, Copy, PartialEq, Eq)]
 pub struct MessageHeader {
     pub length: u32,
     pub stream_id: u32,
@@ -150,7 +150,7 @@ impl MessageHeader {
 }
 
 /// Generic message of ttrpc.
-#[derive(Default, Debug, Clone, PartialEq)]
+#[derive(Default, Debug, Clone, PartialEq, Eq)]
 pub struct GenMessage {
     pub header: MessageHeader,
     pub payload: Vec<u8>,
@@ -236,7 +236,7 @@ impl<M: protobuf::Message> Codec for M {
 }
 
 /// Message of ttrpc.
-#[derive(Default, Debug, Clone, PartialEq)]
+#[derive(Default, Debug, Clone, PartialEq, Eq)]
 pub struct Message<C> {
     pub header: MessageHeader,
     pub payload: C,