From c14eb282236038a3e1ca37275b309c83f8ddd2d7 Mon Sep 17 00:00:00 2001 From: Erick Tryzelaar Date: Tue, 1 Sep 2015 09:09:04 -0700 Subject: [PATCH] Remove unused buf module. --- serde/src/buf.rs | 96 ------------------------------------------------ 1 file changed, 96 deletions(-) delete mode 100644 serde/src/buf.rs diff --git a/serde/src/buf.rs b/serde/src/buf.rs deleted file mode 100644 index 42b9185f..00000000 --- a/serde/src/buf.rs +++ /dev/null @@ -1,96 +0,0 @@ -#![allow(missing_docs)] - -use std::cmp; -use std::io; -use std::slice; - -trait IntoBufRead { - type IntoBuf: io::BufRead + BufReadExt; - - fn into_buf_read(self) -> Self::IntoBuf; -} - -trait BufReadExt { - fn get_buf(&self) -> &[u8]; - fn read_u8(&mut self) -> io::Result>; -} - -struct SliceReader<'a> { - buf: &'a [u8], -} - -impl<'a> io::Read for SliceReader<'a> { - #[inline] - fn read(&mut self, buf: &mut [u8]) -> io::Result { - let amt = cmp::min(buf.len(), self.buf.len()); - let (a, b) = self.buf.split_at(amt); - slice::bytes::copy_memory(buf, a); - *self.buf = b; - Ok(amt) - } -} - -impl<'a> io::BufRead for SliceReader<'a> { - fn fill_buf(&mut self) -> io::Result<&[u8]> { Ok(*self) } - fn consume(&mut self, amt: usize) { *self.buf = &self.buf[amt..]; } -} - -impl<'a> BufReadExt for SliceReader<'a> { - fn get_buf(&self) -> &[u8] { self.buf } - fn read_u8(&mut self) -> io::Result> { - let byte = self.buf.get(0); - *self.buf = &self.buf[1..]; - byte - } -} - -struct BufReader { - inner: R, - buf: io::Cursor>, -} - -impl BufReader where R: io::Read { - fn new(inner: R) -> Self { - BufferedReader::with_capacity(io::DEFAULT_BUF_SIZE, inner) - } - - fn new(cap: usize, inner: R) -> Self { - BufferedReader { - inner: inner, - buf: io::Cursor::new(Vec::with_capacity(cap)), - } - } - - fn into_inner(self) -> R { - self.inner - } -} - -impl Read for BufReader where R: io::Read { - fn read(&mut self, buf: &mut [u8]) -> io::Result { - // If we don't have any buffered data and we're doing a massive read - // (larger than our internal buffer), bypass our internal buffer - // entirely. - if self.buf.get_ref().len() == self.buf.position() as usize && - buf.len() >= self.buf.get_ref().capacity() { - return self.inner.read(buf); - } - try!(self.fill_buf()); - self.buf.read(buf) - } -} - -impl BufReadExt for BufReader { - fn get_buf(&self) -> &[u8] { - self.buf.get_ref() - } - - fn read_u8(&mut self) -> io::Result> { - if self.buf.get_ref().len() == self.buf.position() as usize { - - } - let byte = self.buf.get(0); - *self.buf = &self.buf[1..]; - byte - } -}