We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 12c5918 commit 9af3dbfCopy full SHA for 9af3dbf
compio/benches/net.rs
@@ -30,8 +30,7 @@ fn echo_tokio(b: &mut Bencher, content: &[u8; BUFFER_SIZE]) {
30
let start = Instant::now();
31
for _i in 0..iter {
32
let (mut tx, (mut rx, _)) =
33
- futures_util::try_join!(tokio::net::TcpStream::connect(addr), listener.accept())
34
- .unwrap();
+ tokio::try_join!(tokio::net::TcpStream::connect(addr), listener.accept()).unwrap();
35
36
let client = async move {
37
let mut buffer = [0u8; BUFFER_SIZE];
@@ -47,7 +46,7 @@ fn echo_tokio(b: &mut Bencher, content: &[u8; BUFFER_SIZE]) {
47
46
rx.write_all(&buffer).await.unwrap();
48
}
49
};
50
- futures_util::join!(client, server);
+ tokio::join!(client, server);
51
52
start.elapsed()
53
})
0 commit comments