fix test start server listen both socket address

Author: lamb

lib/src/http/stream.rs

@@ -121,8 +121,14 @@ impl AsyncWrite for Stream {
 async fn test_connect() {
     crate::tests::start_server(30000).await;
     let stream = Stream::connect(&Url::from("http://127.0.0.1:30000/get"), Duration::from_secs(2)).await;
+    if let Err(error) = stream.as_ref() {
+        println!("{:?}", error);
+    }
     assert!(stream.is_ok());
     let stream = Stream::connect(&Url::from("http://localhost:30000/get"), Duration::from_secs(2)).await;
+    if let Err(error) = stream.as_ref() {
+        println!("{:?}", error);
+    }
     assert!(stream.is_ok());
     let stream = Stream::connect(&Url::from("http://localhost:88/get"), Duration::from_secs(2)).await;
     assert!(stream.is_err());

lib/src/lib.rs

@@ -37,6 +37,11 @@ pub mod tests {
     use serde_json::json;
     use serde_json::Value;
     use std::collections::HashMap;
+    use std::net::IpAddr;
+    use std::net::Ipv4Addr;
+    use std::net::Ipv6Addr;
+    use std::net::SocketAddr;
+    use tokio::net::TcpListener;
 
     pub async fn start_server(port: u16) {
         let router = Router::new()
@@ -45,10 +50,19 @@ pub mod tests {
             .route("/json", post(handle_json))
             .route("/form", post(handle_form))
             .route("/multipart", post(handle_multipart));
-
-        let listener = tokio::net::TcpListener::bind(("127.0.0.1", port)).await.unwrap();
-        tokio::spawn(async move {
-            axum::serve(listener, router).await.unwrap();
+        let listeners = [
+            TcpListener::bind(SocketAddr::new(IpAddr::from(Ipv4Addr::UNSPECIFIED), port))
+                .await
+                .unwrap(),
+            TcpListener::bind(SocketAddr::new(IpAddr::from(Ipv6Addr::UNSPECIFIED), port))
+                .await
+                .unwrap(),
+        ];
+        listeners.into_iter().for_each(|listener| {
+            let router = router.to_owned();
+            tokio::spawn(async move {
+                axum::serve(listener, router).await.unwrap();
+            });
         });
     }