diff --git a/linkerd/http/prom/src/body_data/response.rs b/linkerd/http/prom/src/body_data/response.rs index f7999a9f4d..6463f3ba44 100644 --- a/linkerd/http/prom/src/body_data/response.rs +++ b/linkerd/http/prom/src/body_data/response.rs @@ -86,20 +86,9 @@ where let Self { inner, metrics } = self; let metrics = metrics.clone(); - let instrument = Box::new(|resp| Self::instrument_response(resp, metrics)); - - inner.call(req).map_ok(instrument).boxed() - } -} - -impl RecordBodyData { - fn instrument_response(resp: Response, metrics: BodyDataMetrics) -> Response - where - B: Body + Send + 'static, - B::Data: Send + 'static, - B::Error: Into, - { - resp.map(|b| super::body::Body::new(b, metrics)) - .map(BoxBody::new) + inner + .call(req) + .map_ok(|rsp| rsp.map(|b| BoxBody::new(super::body::Body::new(b, metrics)))) + .boxed() } }