Preserve service error type in RequestDecompression

tower-rs · May 17, 2023 · e139528 · e139528
1 parent d22f200
commit e139528
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 7 deletions.
diff --git a/tower-http/src/decompression/request/future.rs b/tower-http/src/decompression/request/future.rs
@@ -67,16 +67,14 @@ where
     B: Body + Send + 'static,
     B::Data: Buf + 'static,
     B::Error: Into<BoxError> + 'static,
-    E: Into<BoxError>,
 {
-    type Output = Result<Response<UnsyncBoxBody<B::Data, BoxError>>, BoxError>;
+    type Output = Result<Response<UnsyncBoxBody<B::Data, BoxError>>, E>;
 
     fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
         match self.project().kind.project() {
             StateProj::Inner { fut } => fut
                 .poll(cx)
-                .map_ok(|res| res.map(|body| body.map_err(Into::into).boxed_unsync()))
-                .map_err(Into::into),
+                .map_ok(|res| res.map(|body| body.map_err(Into::into).boxed_unsync())),
             StateProj::Unsupported { accept } => {
                 let res = Response::builder()
                     .header(

diff --git a/tower-http/src/decompression/request/service.rs b/tower-http/src/decompression/request/service.rs
@@ -42,16 +42,15 @@ where
     S: Service<Request<DecompressionBody<ReqBody>>, Response = Response<ResBody>>,
     ReqBody: Body,
     ResBody: Body<Data = D> + Send + 'static,
-    S::Error: Into<BoxError>,
     <ResBody as Body>::Error: Into<BoxError>,
     D: Buf + 'static,
 {
     type Response = Response<UnsyncBoxBody<D, BoxError>>;
-    type Error = BoxError;
+    type Error = S::Error;
     type Future = ResponseFuture<S::Future, ResBody, S::Error>;
 
     fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), Self::Error>> {
-        self.inner.poll_ready(cx).map_err(Into::into)
+        self.inner.poll_ready(cx)
     }
 
     fn call(&mut self, req: Request<ReqBody>) -> Self::Future {