Skip to content

Commit ed05ea1

Browse files
committed
---
yaml --- r: 271817 b: refs/heads/auto c: 6489fb4 h: refs/heads/master i: 271815: e3e6875
1 parent 3a6ae59 commit ed05ea1

File tree

2 files changed

+32
-2
lines changed

2 files changed

+32
-2
lines changed

[refs]

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@ refs/tags/release-0.3: b5f0d0f648d9a6153664837026ba1be43d3e2503
88
refs/tags/release-0.3.1: 495bae036dfe5ec6ceafd3312b4dca48741e845b
99
refs/tags/release-0.4: e828ea2080499553b97dfe33b3f4d472b4562ad7
1010
refs/tags/release-0.5: 7e3bcfbf21278251ee936ad53e92e9b719702d73
11-
refs/heads/auto: 373f93a629313dccd1858e403e99fb25709947a4
11+
refs/heads/auto: 6489fb40deeb7ac62ca11439f96fdb4124c6b94f
1212
refs/tags/release-0.6: b4ebcfa1812664df5e142f0134a5faea3918544c
1313
refs/tags/0.1: b19db808c2793fe2976759b85a355c3ad8c8b336
1414
refs/tags/0.2: 1754d02027f2924bed83b0160ee340c7f41d5ea1

branches/auto/src/libstd/io/mod.rs

Lines changed: 31 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1446,7 +1446,7 @@ impl<T: Read, U: Read> Read for Chain<T, U> {
14461446
impl<T: BufRead, U: BufRead> BufRead for Chain<T, U> {
14471447
fn fill_buf(&mut self) -> Result<&[u8]> {
14481448
if !self.done_first {
1449-
match try!(self.first.fill_buf()) {
1449+
match self.first.fill_buf()? {
14501450
buf if buf.len() == 0 => { self.done_first = true; }
14511451
buf => return Ok(buf),
14521452
}
@@ -1865,6 +1865,36 @@ mod tests {
18651865
assert_eq!(0, R.take(0).read(&mut buf).unwrap());
18661866
}
18671867

1868+
fn cmp_bufread<Br1: BufRead, Br2: BufRead>(mut br1: Br1, mut br2: Br2, exp: &[u8]) {
1869+
let mut cat = Vec::new();
1870+
loop {
1871+
let consume = {
1872+
let buf1 = br1.fill_buf().unwrap();
1873+
let buf2 = br2.fill_buf().unwrap();
1874+
let minlen = if buf1.len() < buf2.len() { buf1.len() } else { buf2.len() };
1875+
assert_eq!(buf1[..minlen], buf2[..minlen]);
1876+
cat.extend_from_slice(&buf1[..minlen]);
1877+
minlen
1878+
};
1879+
if consume == 0 {
1880+
break;
1881+
}
1882+
br1.consume(consume);
1883+
br2.consume(consume);
1884+
}
1885+
assert_eq!(br1.fill_buf().unwrap().len(), 0);
1886+
assert_eq!(br2.fill_buf().unwrap().len(), 0);
1887+
assert_eq!(&cat[..], &exp[..])
1888+
}
1889+
1890+
#[test]
1891+
fn chain_bufread() {
1892+
let testdata = b"ABCDEFGHIJKL";
1893+
let chain1 = (&testdata[..3]).chain(&testdata[3..6]).chain(&testdata[6..9]).chain(&testdata[9..]);
1894+
let chain2 = (&testdata[..4]).chain(&testdata[4..8]).chain(&testdata[8..]);
1895+
cmp_bufread(chain1, chain2, &testdata[..]);
1896+
}
1897+
18681898
#[bench]
18691899
fn bench_read_to_end(b: &mut test::Bencher) {
18701900
b.iter(|| {

0 commit comments

Comments
 (0)