We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
RecordBodyData<S>
1 parent 5a1a978 commit f147343Copy full SHA for f147343
linkerd/http/prom/src/body_data/response.rs
@@ -86,20 +86,9 @@ where
86
87
let Self { inner, metrics } = self;
88
let metrics = metrics.clone();
89
- let instrument = Box::new(|resp| Self::instrument_response(resp, metrics));
90
-
91
- inner.call(req).map_ok(instrument).boxed()
92
- }
93
-}
94
95
-impl<S> RecordBodyData<S> {
96
- fn instrument_response<B>(resp: Response<B>, metrics: BodyDataMetrics) -> Response<BoxBody>
97
- where
98
- B: Body + Send + 'static,
99
- B::Data: Send + 'static,
100
- B::Error: Into<Error>,
101
- {
102
- resp.map(|b| super::body::Body::new(b, metrics))
103
- .map(BoxBody::new)
+ inner
+ .call(req)
+ .map_ok(|rsp| rsp.map(|b| BoxBody::new(super::body::Body::new(b, metrics))))
+ .boxed()
104
}
105
0 commit comments