diff --git a/Cargo.lock b/Cargo.lock index aacb950d..273422d0 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -5073,9 +5073,9 @@ checksum = "1f3ccbac311fea05f86f61904b462b55fb3df8837a366dfc601a0161d0532f20" [[package]] name = "tokio" -version = "1.42.0" +version = "1.44.2" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "5cec9b21b0450273377fc97bd4c33a8acffc8c996c987a7c5b319a0083707551" +checksum = "e6b88822cbe49de4185e3a4cbf8321dd487cf5fe0c5c65695fef6346371e9c48" dependencies = [ "backtrace", "bytes", @@ -5091,9 +5091,9 @@ dependencies = [ [[package]] name = "tokio-macros" -version = "2.4.0" +version = "2.5.0" source = "registry+https://github.com/rust-lang/crates.io-index" -checksum = "693d596312e88961bc67d7f1f97af8a70227d9f90c31bba5806eec004978d752" +checksum = "6e06d43f1345a3bcd39f6a56dbb7dcab2ba47e68e8ac134855e7e2bdbaf8cab8" dependencies = [ "proc-macro2", "quote", diff --git a/axum/Cargo.toml b/axum/Cargo.toml index 556ff948..41453965 100644 --- a/axum/Cargo.toml +++ b/axum/Cargo.toml @@ -81,7 +81,7 @@ serde_json = { version = "1.0", features = ["raw_value"], optional = true } serde_path_to_error = { version = "0.1.8", optional = true } serde_urlencoded = { version = "0.7", optional = true } sha1 = { version = "0.10", optional = true } -tokio = { package = "tokio", version = "1.25.0", features = ["time"], optional = true } +tokio = { package = "tokio", version = "1.44", features = ["time"], optional = true } tokio-tungstenite = { version = "0.26.0", optional = true } tracing = { version = "0.1", default-features = false, optional = true } @@ -131,7 +131,7 @@ reqwest = { version = "0.12", default-features = false, features = ["json", "str serde = { version = "1.0", features = ["derive"] } serde_json = { version = "1.0", features = ["raw_value"] } time = { version = "0.3", features = ["serde-human-readable"] } -tokio = { package = "tokio", version = "1.25.0", features = ["macros", "rt", "rt-multi-thread", "net", "test-util"] } +tokio = { package = "tokio", version = "1.44.2", features = ["macros", "rt", "rt-multi-thread", "net", "test-util"] } tokio-stream = "0.1" tokio-tungstenite = "0.26.0" tracing = "0.1" diff --git a/axum/src/serve/mod.rs b/axum/src/serve/mod.rs index ca673b44..b6b15265 100644 --- a/axum/src/serve/mod.rs +++ b/axum/src/serve/mod.rs @@ -6,7 +6,6 @@ use std::{ future::{poll_fn, Future, IntoFuture}, io, marker::PhantomData, - sync::Arc, }; use axum_core::{body::Body, extract::Request, response::Response}; @@ -293,7 +292,6 @@ where } = self; let (signal_tx, signal_rx) = watch::channel(()); - let signal_tx = Arc::new(signal_tx); tokio::spawn(async move { signal.await; trace!("received graceful shutdown signal. Telling tasks to shutdown"); @@ -330,7 +328,7 @@ where let hyper_service = TowerToHyperService::new(tower_service); - let signal_tx = Arc::clone(&signal_tx); + let signal_tx = signal_tx.clone(); let close_rx = close_rx.clone();