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

The error type shuld more friendly to external interfaces

Signed-off-by: jokemanfire <[email protected]>

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(|e| 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?;