tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-08-29 00:00:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

tests: complete TODOs in uds_stream (#4587)

Browse Source
This commit is contained in:
Arash Sal Moslehian
2022-03-28 19:58:06 +00:00
committed by GitHub
parent a05135a4f8
commit 702d6dccc9
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/tests/uds_stream.rs
+6 -6
View File
@@ -25,13 +25,13 @@ async fn accept_read_write() -> std::io::Result<()> {
let connect = UnixStream::connect(&sock_path); let connect = UnixStream::connect(&sock_path);
let ((mut server, _), mut client) = try_join(accept, connect).await?; let ((mut server, _), mut client) = try_join(accept, connect).await?;
// Write to the client. TODO: Switch to write_all. // Write to the client.
let write_len = client.write(b"hello").await?; client.write_all(b"hello").await?;
assert_eq!(write_len, 5);
drop(client); drop(client);
// Read from the server. TODO: Switch to read_to_end.
let mut buf = [0u8; 5]; // Read from the server.
server.read_exact(&mut buf).await?; let mut buf = vec![];
server.read_to_end(&mut buf).await?;
assert_eq!(&buf, b"hello"); assert_eq!(&buf, b"hello");
let len = server.read(&mut buf).await?; let len = server.read(&mut buf).await?;
assert_eq!(len, 0); assert_eq!(len, 0);