From 6587b6539386e55635a10a64611eaddb4cfbacdd Mon Sep 17 00:00:00 2001 From: Jonas Platte Date: Sat, 26 Apr 2025 21:22:07 +0200 Subject: [PATCH] Replace futures_util::pin_mut with std::pin::pin --- axum/src/serve/mod.rs | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/axum/src/serve/mod.rs b/axum/src/serve/mod.rs index b6b15265..f5d3b129 100644 --- a/axum/src/serve/mod.rs +++ b/axum/src/serve/mod.rs @@ -6,10 +6,11 @@ use std::{ future::{poll_fn, Future, IntoFuture}, io, marker::PhantomData, + pin::pin, }; use axum_core::{body::Body, extract::Request, response::Response}; -use futures_util::{pin_mut, FutureExt}; +use futures_util::FutureExt; use hyper::body::Incoming; use hyper_util::rt::{TokioExecutor, TokioIo}; #[cfg(any(feature = "http1", feature = "http2"))] @@ -338,11 +339,9 @@ where // CONNECT protocol needed for HTTP/2 websockets #[cfg(feature = "http2")] builder.http2().enable_connect_protocol(); - let conn = builder.serve_connection_with_upgrades(io, hyper_service); - pin_mut!(conn); - let signal_closed = signal_tx.closed().fuse(); - pin_mut!(signal_closed); + let mut conn = pin!(builder.serve_connection_with_upgrades(io, hyper_service)); + let mut signal_closed = pin!(signal_tx.closed().fuse()); loop { tokio::select! {