Add delay for test server availability, could cause connect race

ntex-server/src/net/test.rs

@@ -59,17 +59,19 @@ where
                 .workers(1)
                 .disable_signals()
                 .run();
-            tx.send((system, local_addr, server))
+
-                .expect("Failed to send Server to TestServer");
+            ntex_rt::spawn(async move {
+                ntex_util::time::sleep(ntex_util::time::Millis(75)).await;
+                tx.send((system, local_addr, server))
+                    .expect("Failed to send Server to TestServer");
+            });
+
             Ok(())
         })
     });
 
     let (system, addr, server) = rx.recv().unwrap();
 
-    // wait for server
-    thread::sleep(std::time::Duration::from_millis(50));
-
     TestServer {
         addr,
         server,

ntex/CHANGES.md

@@ -1,5 +1,9 @@
 # Changes
 
+## [2.12.3] - 2025-03-xx
+
+* http: Add delay for test server availability, could cause connect race
+
 ## [2.12.2] - 2025-03-15
 
 * http: Allow to run publish future to completion in case error

ntex/src/http/test.rs

@@ -244,6 +244,11 @@ where
                 .workers(1)
                 .disable_signals()
                 .run();
+
+            crate::rt::spawn(async move {
+                sleep(Millis(75)).await;
+                tx.send((System::current(), srv, local_addr)).unwrap();
+            });
             tx.send((system, srv, local_addr)).unwrap();
             Ok(())
         })

ntex/src/web/test.rs

@@ -697,7 +697,10 @@ where
             .set_tag("test", "WEB-SRV")
             .run();
 
-            tx.send((System::current(), srv, local_addr)).unwrap();
+            crate::rt::spawn(async move {
+                sleep(Millis(75)).await;
+                tx.send((System::current(), srv, local_addr)).unwrap();
+            });
             Ok(())
         })
     });