diff --git a/volo-grpc/src/layer/loadbalance/mod.rs b/volo-grpc/src/layer/loadbalance/mod.rs index 3695b819..e59ae5c8 100644 --- a/volo-grpc/src/layer/loadbalance/mod.rs +++ b/volo-grpc/src/layer/loadbalance/mod.rs @@ -97,7 +97,7 @@ where .await .map_err(|err| err.into())?, _ => { - return self.service.call(cx, req).await.map_err(Into::into); + return self.service.call(cx, req).await; } }; diff --git a/volo-thrift/src/client/layer/timeout.rs b/volo-thrift/src/client/layer/timeout.rs index 098c6509..f26410e9 100644 --- a/volo-thrift/src/client/layer/timeout.rs +++ b/volo-thrift/src/client/layer/timeout.rs @@ -25,7 +25,7 @@ where Some(duration) => { let start = std::time::Instant::now(); match tokio::time::timeout(duration, self.inner.call(cx, req)).await { - Ok(r) => r.map_err(Into::into), + Ok(r) => r, Err(_) => { let msg = format!( "[VOLO] thrift rpc call timeout, rpcinfo: {:?}, elpased: {:?}, \ @@ -43,7 +43,7 @@ where } } } - None => self.inner.call(cx, req).await.map_err(Into::into), + None => self.inner.call(cx, req).await, } } } diff --git a/volo-thrift/src/transport/pool/make_transport.rs b/volo-thrift/src/transport/pool/make_transport.rs index 1eed6048..4405c580 100644 --- a/volo-thrift/src/transport/pool/make_transport.rs +++ b/volo-thrift/src/transport/pool/make_transport.rs @@ -54,6 +54,6 @@ where async fn call(&self, kv: (K, Ver)) -> Result { let mt = self.inner.clone(); - self.pool.get(kv.0, kv.1, mt).await.map_err(Into::into) + self.pool.get(kv.0, kv.1, mt).await } }