async-client: remove client timeout

After the server-timeout feature had been introduced,
the client timeout feature is unnecessary and can be removed.

Signed-off-by: Tim Zhang <[email protected]>

Author: Tim-Zhang

src/asynchronous/client.rs

@@ -8,7 +8,6 @@ use protobuf::{CodedInputStream, CodedOutputStream, Message};
 use std::collections::HashMap;
 use std::os::unix::io::RawFd;
 use std::sync::{Arc, Mutex};
-use std::time::Duration;
 
 use crate::common::MESSAGE_TYPE_RESPONSE;
 use crate::error::{Error, Result};
@@ -21,7 +20,6 @@ use tokio::{
     io::{split, AsyncWriteExt},
     sync::mpsc::{channel, Receiver, Sender},
     sync::Notify,
-    time::timeout,
 };
 
 type RequestSender = Sender<(Vec<u8>, Sender<Result<Vec<u8>>>)>;
@@ -158,21 +156,10 @@ impl Client {
             .await
             .map_err(|e| Error::Others(format!("Send packet to sender error {:?}", e)))?;
 
-        let result: Result<Vec<u8>> = if req.timeout_nano == 0 {
-            rx.recv()
-                .await
-                .ok_or_else(|| Error::Others("Recive packet from recver error".to_string()))?
-        } else {
-            match timeout(Duration::from_nanos(req.timeout_nano as u64), rx.recv()).await {
-                Ok(result) => result
-                    .ok_or_else(|| Error::Others("Recive packet from recver error".to_string()))?,
-                Err(_) => {
-                    return Err(Error::Others(
-                        "Recive packet from recver error: timeout".to_string(),
-                    ))
-                }
-            }
-        };
+        let result = rx
+            .recv()
+            .await
+            .ok_or_else(|| Error::Others("Recive packet from recver error".to_string()))?;
 
         let buf = result?;
         let mut s = CodedInputStream::from_bytes(&buf);