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 d8fd40c commit 24023fdCopy full SHA for 24023fd
compio-io/tests/io.rs
@@ -2,7 +2,7 @@ use std::io::Cursor;
2
3
use compio_buf::{arrayvec::ArrayVec, BufResult, IoBuf, IoBufMut};
4
use compio_io::{
5
- AsyncRead, AsyncReadAt, AsyncReadAtExt, AsyncReadExt, AsyncWrite, AsyncWriteAt,
+ split, AsyncRead, AsyncReadAt, AsyncReadAtExt, AsyncReadExt, AsyncWrite, AsyncWriteAt,
6
AsyncWriteAtExt, AsyncWriteExt,
7
};
8
@@ -355,3 +355,19 @@ async fn read_to_end_at() {
355
assert_eq!(len, 4);
356
assert_eq!(buf, [4, 5, 1, 4]);
357
}
358
+
359
+#[tokio::test]
360
+async fn split_unsplit() {
361
+ let src = Cursor::new([1, 1, 4, 5, 1, 4]);
362
+ let (mut read, mut write) = split(src);
363
364
+ let (len, buf) = read.read([0, 0, 0]).await.unwrap();
365
+ assert_eq!(len, 3);
366
+ assert_eq!(buf, [1, 1, 4]);
367
368
+ let (len, _) = write.write([2, 2, 2]).await.unwrap();
369
370
371
+ let src = read.unsplit(write);
372
+ assert_eq!(src.into_inner(), [1, 1, 4, 2, 2, 2]);
373
+}
0 commit comments