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

Fix tests on nightly

Browse Source 
Closes #83
This commit is contained in:
Carl Lerche
2017-03-19 09:08:41 -07:00
parent 99fba239db
commit 9a4018e757
1 changed files with 33 additions and 24 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tests/test_chain.rs
+33 -24
View File
@@ -53,41 +53,50 @@ fn vectored_read() {
let b = Cursor::new(Bytes::from(&b"world"[..])); let b = Cursor::new(Bytes::from(&b"world"[..]));
let mut buf = a.chain(b); let mut buf = a.chain(b);
let mut iovecs: [&IoVec; 4] = Default::default();
assert_eq!(2, buf.bytes_vec(&mut iovecs)); {
assert_eq!(iovecs[0][..], b"hello"[..]); let mut iovecs: [&IoVec; 4] = Default::default();
assert_eq!(iovecs[1][..], b"world"[..]);
assert!(iovecs[2].is_empty()); assert_eq!(2, buf.bytes_vec(&mut iovecs));
assert!(iovecs[3].is_empty()); assert_eq!(iovecs[0][..], b"hello"[..]);
assert_eq!(iovecs[1][..], b"world"[..]);
assert!(iovecs[2].is_empty());
assert!(iovecs[3].is_empty());
}
buf.advance(2); buf.advance(2);
iovecs = Default::default(); {
let mut iovecs: [&IoVec; 4] = Default::default();
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!(iovecs[2].is_empty());
assert!(iovecs[3].is_empty()); assert!(iovecs[3].is_empty());
}
buf.advance(3); buf.advance(3);
iovecs = Default::default(); {
let mut iovecs: [&IoVec; 4] = Default::default();
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!(iovecs[1].is_empty());
assert!(iovecs[2].is_empty()); assert!(iovecs[2].is_empty());
assert!(iovecs[3].is_empty()); assert!(iovecs[3].is_empty());
}
buf.advance(3); buf.advance(3);
iovecs = Default::default(); {
let mut iovecs: [&IoVec; 4] = Default::default();
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!(iovecs[1].is_empty());
assert!(iovecs[2].is_empty()); assert!(iovecs[2].is_empty());
assert!(iovecs[3].is_empty()); assert!(iovecs[3].is_empty());
}
} }