diff --git a/proxy/src/telemetry/sensor/http.rs b/proxy/src/telemetry/sensor/http.rs
index 895188e6f..c9177938b 100644
--- a/proxy/src/telemetry/sensor/http.rs
+++ b/proxy/src/telemetry/sensor/http.rs
@@ -507,6 +507,14 @@ where
 
 }
 
+impl<B, I: BodySensor> Drop for MeasuredBody<B, I> {
+    fn drop(&mut self) {
+        if let Some(inner) = self.inner.take() {
+            inner.end(None);
+        }
+    }
+}
+
 // ===== impl BodySensor =====
 
 impl BodySensor for ResponseBodyInner {