test(io): test bufread for AsyncStream

Author: Berrysoft

compio-io/tests/compat.rs

@@ -1,7 +1,7 @@
 use std::io::Cursor;
 
 use compio_io::compat::AsyncStream;
-use futures_util::{AsyncReadExt, AsyncWriteExt};
+use futures_util::{AsyncBufReadExt, AsyncReadExt, AsyncWriteExt};
 
 #[tokio::test]
 async fn async_compat_read() {
@@ -20,6 +20,22 @@ async fn async_compat_read() {
     assert_eq!(&buf[..7], [1, 9, 1, 9, 8, 1, 0]);
 }
 
+#[tokio::test]
+async fn async_compat_bufread() {
+    let src = &[1u8, 1, 4, 5, 1, 4, 1, 9, 1, 9, 8, 1, 0][..];
+    let mut stream = AsyncStream::new(src);
+
+    let slice = stream.fill_buf().await.unwrap();
+    assert_eq!(slice, [1, 1, 4, 5, 1, 4, 1, 9, 1, 9, 8, 1, 0]);
+    stream.consume_unpin(6);
+
+    let mut buf = [0; 7];
+    let len = stream.read(&mut buf).await.unwrap();
+
+    assert_eq!(len, 7);
+    assert_eq!(buf, [1, 9, 1, 9, 8, 1, 0]);
+}
+
 #[tokio::test]
 async fn async_compat_write() {
     let dst = Cursor::new([0u8; 10]);