test(net): try to find out why it blocks

Remove the channel and wait for the spawned task directly.

Author: Berrysoft

compio-net/Cargo.toml

@@ -39,6 +39,5 @@ libc = { workspace = true }
 # Shared dev dependencies for all platforms
 [dev-dependencies]
 compio-macros = { workspace = true }
-futures-channel = { workspace = true }
 futures-util = { workspace = true }
 tempfile = { workspace = true }

compio-net/tests/tcp_accept.rs

@@ -3,14 +3,12 @@ use compio_net::{TcpListener, TcpStream, ToSocketAddrsAsync};
 async fn test_impl(addr: impl ToSocketAddrsAsync) {
     let listener = TcpListener::bind(addr).await.unwrap();
     let addr = listener.local_addr().unwrap();
-    let (tx, rx) = futures_channel::oneshot::channel();
-    compio_runtime::spawn(async move {
+    let task = compio_runtime::spawn(async move {
         let (socket, _) = listener.accept().await.unwrap();
-        assert!(tx.send(socket).is_ok());
-    })
-    .detach();
+        socket
+    });
     let cli = TcpStream::connect(&addr).await.unwrap();
-    let srv = rx.await.unwrap();
+    let srv = task.await;
     assert_eq!(cli.local_addr().unwrap(), srv.peer_addr().unwrap());
 }
 

compio-net/tests/tcp_connect.rs

@@ -10,17 +10,14 @@ async fn test_connect_ip_impl(
     let addr = listener.local_addr().unwrap();
     assert!(assert_fn(&addr));
 
-    let (tx, rx) = futures_channel::oneshot::channel();
-
-    compio_runtime::spawn(async move {
+    let task = compio_runtime::spawn(async move {
         let (socket, addr) = listener.accept().await.unwrap();
         assert_eq!(addr, socket.peer_addr().unwrap());
-        assert!(tx.send(socket).is_ok());
-    })
-    .detach();
+        socket
+    });
 
     let mine = TcpStream::connect(&addr).await.unwrap();
-    let theirs = rx.await.unwrap();
+    let theirs = task.await;
 
     assert_eq!(mine.local_addr().unwrap(), theirs.peer_addr().unwrap());
     assert_eq!(theirs.local_addr().unwrap(), mine.peer_addr().unwrap());