Merge pull request #259 from jokemanfire/dev3

async:when the client request failed. Learn from ttrpc-go

Author: Hui Zhu

src/asynchronous/client.rs

@@ -84,20 +84,20 @@ impl Client {
         self.req_tx
             .send(SendingMessage::new(msg))
             .await
-            .map_err(|e| Error::Others(format!("Send packet to sender error {e:?}")))?;
+            .map_err(|_| Error::LocalClosed)?;
 
         let result = if timeout_nano == 0 {
             rx.recv()
                 .await
-                .ok_or_else(|| Error::Others("Receive packet from receiver error".to_string()))?
+                .ok_or_else(|| Error::RemoteClosed)?
         } else {
             tokio::time::timeout(
                 std::time::Duration::from_nanos(timeout_nano as u64),
                 rx.recv(),
             )
             .await
             .map_err(|e| Error::Others(format!("Receive packet timeout {e:?}")))?
-            .ok_or_else(|| Error::Others("Receive packet from receiver error".to_string()))?
+            .ok_or_else(|| Error::RemoteClosed)?
         };
 
         let msg = result?;