Fix async reconnect test

1c3t3a · Mar 19, 2024 · afb2e91 · afb2e91
1 parent b2073c9
commit afb2e91
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/socketio/src/asynchronous/client/client.rs b/socketio/src/asynchronous/client/client.rs
@@ -552,7 +552,7 @@ mod test {
         asynchronous::client::{builder::ClientBuilder, client::Client},
         error::Result,
         packet::{Packet, PacketId},
-        Event, Payload, TransportType,
+        Payload, TransportType,
     };
 
     #[tokio::test]
@@ -735,7 +735,7 @@ mod test {
         let socket = socket.unwrap();
 
         // waiting for server to emit message
-        std::thread::sleep(std::time::Duration::from_millis(500));
+        sleep(Duration::from_millis(500)).await;
 
         assert_eq!(load(&CONNECT_NUM), 1, "should connect once");
         assert_eq!(load(&MESSAGE_NUM), 1, "should receive one");
@@ -745,7 +745,7 @@ mod test {
 
         // waiting for server to restart
         for _ in 0..10 {
-            std::thread::sleep(std::time::Duration::from_millis(400));
+            sleep(Duration::from_millis(400)).await;
             if load(&CONNECT_NUM) == 2 && load(&MESSAGE_NUM) == 2 {
                 break;
             }