From e4aeeeaa1f66d6c72ec9443deb14747a711d8379 Mon Sep 17 00:00:00 2001 From: Raphael Amorim Date: Mon, 15 Jan 2024 17:49:07 +0100 Subject: [PATCH] small changes --- src/middleware/axum.rs | 3 +-- src/test/mod.rs | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/src/middleware/axum.rs b/src/middleware/axum.rs index 0c5a5ba..0722a44 100644 --- a/src/middleware/axum.rs +++ b/src/middleware/axum.rs @@ -64,12 +64,11 @@ where type Future = ResponseFuture; fn poll_ready(&mut self, cx: &mut Context<'_>) -> Poll> { - self.inner.poll_ready(cx).map_err(Into::into) + self.inner.poll_ready(cx) } fn call(&mut self, req: Request) -> Self::Future { use tracing_opentelemetry::OpenTelemetrySpanExt; - let req = req; let span = if self.filter.map_or(true, |f| f(req.uri().path())) { let span = otel_http::http_server::make_span_from_request(&req); let route = http_route(&req); diff --git a/src/test/mod.rs b/src/test/mod.rs index 7cd96ad..5507492 100644 --- a/src/test/mod.rs +++ b/src/test/mod.rs @@ -22,7 +22,7 @@ impl TracedResponse { } #[cfg(feature = "axum")] - pub async fn into_axum_bytes(self) -> Result { + pub async fn into_axum_bytes(self) -> Result { { Ok(self.resp.into_body().collect().await?.to_bytes()) } }