mikros/rust
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Suggested edits

Browse Source
This commit is contained in:
Jonathan Behrens 2018-11-01 13:29:47 -04:00
parent 07d966dbb8
commit 40e41440e4
1 changed files with 24 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
src/libstd/io/buffered.rs
View File

@ -534,7 +534,7 @@ impl<W: Write> BufWriter<W> {
/// use std::io::BufWriter;
/// use std::net::TcpStream;
///
/// let mut buf_writer = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
/// let buf_writer = BufWriter::new(TcpStream::connect("127.0.0.1:34254").unwrap());
///
/// // See how many bytes are currently buffered
/// let bytes_buffered = buf_writer.buffer().len();
@ -985,30 +985,30 @@ mod tests {
let nread = reader.read(&mut buf);
assert_eq!(nread.unwrap(), 3);
assert_eq!(buf, [5, 6, 7]);
assert_eq!(*reader.buffer(), []);
assert_eq!(reader.buffer(), []);
let mut buf = [0, 0];
let nread = reader.read(&mut buf);
assert_eq!(nread.unwrap(), 2);
assert_eq!(buf, [0, 1]);
assert_eq!(*reader.buffer(), []);
assert_eq!(reader.buffer(), []);
let mut buf = [0];
let nread = reader.read(&mut buf);
assert_eq!(nread.unwrap(), 1);
assert_eq!(buf, [2]);
assert_eq!(*reader.buffer(), [3]);
assert_eq!(reader.buffer(), [3]);
let mut buf = [0, 0, 0];
let nread = reader.read(&mut buf);
assert_eq!(nread.unwrap(), 1);
assert_eq!(buf, [3, 0, 0]);
assert_eq!(*reader.buffer(), []);
assert_eq!(reader.buffer(), []);
let nread = reader.read(&mut buf);
assert_eq!(nread.unwrap(), 1);
assert_eq!(buf, [4, 0, 0]);
assert_eq!(*reader.buffer(), []);
assert_eq!(reader.buffer(), []);
assert_eq!(reader.read(&mut buf).unwrap(), 0);
}
@ -1097,41 +1097,41 @@ mod tests {
let mut writer = BufWriter::with_capacity(2, inner);
writer.write(&[0, 1]).unwrap();
assert_eq!(*writer.buffer(), []);
assert_eq!(*writer.get_ref(), [0, 1]);
assert_eq!(writer.buffer(), []);
assert_eq!(writer.get_ref(), [0, 1]);
writer.write(&[2]).unwrap();
assert_eq!(*writer.buffer(), [2]);
assert_eq!(*writer.get_ref(), [0, 1]);
assert_eq!(writer.buffer(), [2]);
assert_eq!(writer.get_ref(), [0, 1]);
writer.write(&[3]).unwrap();
assert_eq!(*writer.buffer(), [2, 3]);
assert_eq!(*writer.get_ref(), [0, 1]);
assert_eq!(writer.buffer(), [2, 3]);
assert_eq!(writer.get_ref(), [0, 1]);
writer.flush().unwrap();
assert_eq!(*writer.buffer(), []);
assert_eq!(*writer.get_ref(), [0, 1, 2, 3]);
assert_eq!(writer.buffer(), []);
assert_eq!(writer.get_ref(), [0, 1, 2, 3]);
writer.write(&[4]).unwrap();
writer.write(&[5]).unwrap();
assert_eq!(*writer.buffer(), [4, 5]);
assert_eq!(*writer.get_ref(), [0, 1, 2, 3]);
assert_eq!(writer.buffer(), [4, 5]);
assert_eq!(writer.get_ref(), [0, 1, 2, 3]);
writer.write(&[6]).unwrap();
assert_eq!(*writer.buffer(), [6]);
assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5]);
assert_eq!(writer.buffer(), [6]);
assert_eq!(writer.get_ref(), [0, 1, 2, 3, 4, 5]);
writer.write(&[7, 8]).unwrap();
assert_eq!(*writer.buffer(), []);
assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8]);
assert_eq!(writer.buffer(), []);
assert_eq!(writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8]);
writer.write(&[9, 10, 11]).unwrap();
assert_eq!(*writer.buffer(), []);
assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]);
assert_eq!(writer.buffer(), []);
assert_eq!(writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]);
writer.flush().unwrap();
assert_eq!(*writer.buffer(), []);
assert_eq!(*writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]);
assert_eq!(writer.buffer(), []);
assert_eq!(writer.get_ref(), [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11]);
}
#[test]