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

Get test passing again

Browse Source
This commit is contained in:
Carl Lerche
2017-10-21 15:47:45 -07:00
parent 03d501b18d
commit 149922d7cf
2 changed files with 40 additions and 15 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/test_buf.rs
+6 -1
View File
@@ -47,7 +47,12 @@ fn test_get_u16_buffer_underflow() {
#[test] #[test]
fn test_bufs_vec() { fn test_bufs_vec() {
let buf = Cursor::new(b"hello world"); let buf = Cursor::new(b"hello world");
let mut dst: [&IoVec; 2] = Default::default();
let b1: &[u8] = &mut [0];
let b2: &[u8] = &mut [0];
let mut dst: [&IoVec; 2] =
[b1.into(), b2.into()];
assert_eq!(1, buf.bytes_vec(&mut dst[..])); assert_eq!(1, buf.bytes_vec(&mut dst[..]));
} }
tests/test_chain.rs
+34 -14
View File
@@ -55,48 +55,68 @@ fn vectored_read() {
let mut buf = a.chain(b); let mut buf = a.chain(b);
{ {
let mut iovecs: [&IoVec; 4] = Default::default(); let b1: &[u8] = &mut [0];
let b2: &[u8] = &mut [0];
let b3: &[u8] = &mut [0];
let b4: &[u8] = &mut [0];
let mut iovecs: [&IoVec; 4] =
[b1.into(), b2.into(), b3.into(), b4.into()];
assert_eq!(2, buf.bytes_vec(&mut iovecs)); assert_eq!(2, buf.bytes_vec(&mut iovecs));
assert_eq!(iovecs[0][..], b"hello"[..]); assert_eq!(iovecs[0][..], b"hello"[..]);
assert_eq!(iovecs[1][..], b"world"[..]); assert_eq!(iovecs[1][..], b"world"[..]);
assert!(iovecs[2].is_empty()); assert_eq!(iovecs[2][..], b"\0"[..]);
assert!(iovecs[3].is_empty()); assert_eq!(iovecs[3][..], b"\0"[..]);
} }
buf.advance(2); buf.advance(2);
{ {
let mut iovecs: [&IoVec; 4] = Default::default(); let b1: &[u8] = &mut [0];
let b2: &[u8] = &mut [0];
let b3: &[u8] = &mut [0];
let b4: &[u8] = &mut [0];
let mut iovecs: [&IoVec; 4] =
[b1.into(), b2.into(), b3.into(), b4.into()];
assert_eq!(2, buf.bytes_vec(&mut iovecs)); assert_eq!(2, buf.bytes_vec(&mut iovecs));
assert_eq!(iovecs[0][..], b"llo"[..]); assert_eq!(iovecs[0][..], b"llo"[..]);
assert_eq!(iovecs[1][..], b"world"[..]); assert_eq!(iovecs[1][..], b"world"[..]);
assert!(iovecs[2].is_empty()); assert_eq!(iovecs[2][..], b"\0"[..]);
assert!(iovecs[3].is_empty()); assert_eq!(iovecs[3][..], b"\0"[..]);
} }
buf.advance(3); buf.advance(3);
{ {
let mut iovecs: [&IoVec; 4] = Default::default(); let b1: &[u8] = &mut [0];
let b2: &[u8] = &mut [0];
let b3: &[u8] = &mut [0];
let b4: &[u8] = &mut [0];
let mut iovecs: [&IoVec; 4] =
[b1.into(), b2.into(), b3.into(), b4.into()];
assert_eq!(1, buf.bytes_vec(&mut iovecs)); assert_eq!(1, buf.bytes_vec(&mut iovecs));
assert_eq!(iovecs[0][..], b"world"[..]); assert_eq!(iovecs[0][..], b"world"[..]);
assert!(iovecs[1].is_empty()); assert_eq!(iovecs[1][..], b"\0"[..]);
assert!(iovecs[2].is_empty()); assert_eq!(iovecs[2][..], b"\0"[..]);
assert!(iovecs[3].is_empty()); assert_eq!(iovecs[3][..], b"\0"[..]);
} }
buf.advance(3); buf.advance(3);
{ {
let mut iovecs: [&IoVec; 4] = Default::default(); let b1: &[u8] = &mut [0];
let b2: &[u8] = &mut [0];
let b3: &[u8] = &mut [0];
let b4: &[u8] = &mut [0];
let mut iovecs: [&IoVec; 4] =
[b1.into(), b2.into(), b3.into(), b4.into()];
assert_eq!(1, buf.bytes_vec(&mut iovecs)); assert_eq!(1, buf.bytes_vec(&mut iovecs));
assert_eq!(iovecs[0][..], b"ld"[..]); assert_eq!(iovecs[0][..], b"ld"[..]);
assert!(iovecs[1].is_empty()); assert_eq!(iovecs[1][..], b"\0"[..]);
assert!(iovecs[2].is_empty()); assert_eq!(iovecs[2][..], b"\0"[..]);
assert!(iovecs[3].is_empty()); assert_eq!(iovecs[3][..], b"\0"[..]);
} }
} }