/// 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();
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);
}
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]