fix(tests): handle timeout layer without breaking subsequent requests

Author: Akagi201

Cargo.toml

@@ -208,7 +208,7 @@ clap = "4.6.1"
 const-oid = "0.10"
 cookie = "0.18.1"
 criterion = "0.8.2"
-cucumber = "0.22.1"
+cucumber = "0.23.0"
 der = "0.8.0"
 digest = "0.11.2"
 encoding_rs = "0.8.35"
@@ -235,7 +235,7 @@ hyper = "1.8.1"
 hyper-util = "0.1.20"
 ipnet = "2.12.0"
 js-sys = "0.3.91"
-libc = "0.2.185"
+libc = "0.2.186"
 md-5 = "0.11.0"
 memchr = "2.8.0"
 mime = "0.3.17"
@@ -254,10 +254,10 @@ pretty_env_logger = "0.5.0"
 proptest = "1.6.0"
 quick-xml = "0.39.2"
 rand = "0.10.1"
-rustls = "0.23.38"
+rustls = "0.23.39"
 rustls-native-certs = "0.8.3"
 rustls-pemfile = "2.2.0"
-rustls-pki-types = "1.14.0"
+rustls-pki-types = "1.14.1"
 rustyline = "18.0.0"
 scc = "3.7.0"
 schnellru = "0.2.4"

crates/hpx/tests/layers.rs

@@ -1,6 +1,12 @@
 mod support;
 
-use std::time::Duration;
+use std::{
+    sync::{
+        Arc,
+        atomic::{AtomicUsize, Ordering},
+    },
+    time::Duration,
+};
 
 use futures_util::future::join_all;
 use hpx::{Body, Client, ClientResponseBody};
@@ -156,6 +162,42 @@ async fn with_connect_timeout_layer_slow() {
     assert!(err.is_timeout());
 }
 
+#[tokio::test]
+async fn timeout_layer_does_not_break_follow_up_requests() {
+    let _ = env_logger::try_init();
+
+    let request_count = Arc::new(AtomicUsize::new(0));
+    let server_count = Arc::clone(&request_count);
+    let server = server::http(move |_req| {
+        let server_count = Arc::clone(&server_count);
+        async move {
+            let current = server_count.fetch_add(1, Ordering::SeqCst);
+            if current == 0 {
+                tokio::time::sleep(Duration::from_millis(200)).await;
+            }
+
+            http::Response::new(hpx::Body::from(format!("response-{current}")))
+        }
+    });
+
+    let url = format!("http://{}/slow", server.addr());
+
+    let client = Client::builder()
+        .layer(TimeoutLayer::new(Duration::from_millis(50)))
+        .no_proxy()
+        .build()
+        .unwrap();
+
+    let first_err = client.get(&url).send().await.unwrap_err();
+    assert!(first_err.is_timeout());
+
+    let second = client.get(&url).send().await.unwrap();
+    let body = second.text().await.unwrap();
+
+    assert_eq!(body, "response-1");
+    assert_eq!(request_count.load(Ordering::SeqCst), 2);
+}
+
 #[tokio::test]
 async fn multiple_timeout_layers_under_threshold() {
     let _ = env_logger::try_init();