use std::io; use std::fmt; use flate2::read::DeflateDecoder; use flate2::read::ZlibDecoder; use bzip2::read::BzDecoder; use super::*; pub struct BufferedReaderDeflate { reader: BufferedReaderGeneric>, } impl BufferedReaderDeflate { pub fn new(reader: R) -> BufferedReaderDeflate { BufferedReaderDeflate { reader: BufferedReaderGeneric::new(DeflateDecoder::new(reader), None) } } } impl io::Read for BufferedReaderDeflate { fn read(&mut self, buf: &mut [u8]) -> Result { self.reader.read(buf) } } impl fmt::Debug for BufferedReaderDeflate { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { f.debug_struct("BufferedReaderDeflate") .field("reader", self.reader.reader.get_ref()) .finish() } } impl BufferedReader for BufferedReaderDeflate { fn data(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data(amount); } fn data_hard(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_hard(amount); } fn data_eof(&mut self) -> Result<&[u8], io::Error> { return self.reader.data_eof(); } fn consume(&mut self, amount: usize) -> &[u8] { return self.reader.consume(amount); } fn data_consume(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_consume(amount); } fn data_consume_hard(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_consume_hard(amount); } fn read_be_u16(&mut self) -> Result { return self.reader.read_be_u16(); } fn read_be_u32(&mut self) -> Result { return self.reader.read_be_u32(); } fn steal(&mut self, amount: usize) -> Result, io::Error> { return self.reader.steal(amount); } fn steal_eof(&mut self) -> Result, io::Error> { return self.reader.steal_eof(); } fn into_inner<'b>(self: Box) -> Option> where Self: 'b { // Strip the outer box. Some(Box::new((*self).reader.reader.into_inner())) } } pub struct BufferedReaderZlib { reader: BufferedReaderGeneric>, } impl BufferedReaderZlib { pub fn new(reader: R) -> BufferedReaderZlib { BufferedReaderZlib { reader: BufferedReaderGeneric::new(ZlibDecoder::new(reader), None) } } } impl io::Read for BufferedReaderZlib { fn read(&mut self, buf: &mut [u8]) -> Result { self.reader.read(buf) } } impl fmt::Debug for BufferedReaderZlib { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { f.debug_struct("BufferedReaderZlib") .field("reader", self.reader.reader.get_ref()) .finish() } } impl BufferedReader for BufferedReaderZlib { fn data(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data(amount); } fn data_hard(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_hard(amount); } fn data_eof(&mut self) -> Result<&[u8], io::Error> { return self.reader.data_eof(); } fn consume(&mut self, amount: usize) -> &[u8] { return self.reader.consume(amount); } fn data_consume(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_consume(amount); } fn data_consume_hard(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_consume_hard(amount); } fn read_be_u16(&mut self) -> Result { return self.reader.read_be_u16(); } fn read_be_u32(&mut self) -> Result { return self.reader.read_be_u32(); } fn steal(&mut self, amount: usize) -> Result, io::Error> { return self.reader.steal(amount); } fn steal_eof(&mut self) -> Result, io::Error> { return self.reader.steal_eof(); } fn into_inner<'b>(self: Box) -> Option> where Self: 'b { // Strip the outer box. Some(Box::new((*self).reader.reader.into_inner())) } } pub struct BufferedReaderBzip { reader: BufferedReaderGeneric>, } impl BufferedReaderBzip { pub fn new(reader: R) -> BufferedReaderBzip { BufferedReaderBzip { reader: BufferedReaderGeneric::new(BzDecoder::new(reader), None) } } } impl io::Read for BufferedReaderBzip { fn read(&mut self, buf: &mut [u8]) -> Result { self.reader.read(buf) } } impl fmt::Debug for BufferedReaderBzip { fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result { f.debug_struct("BufferedReaderBzip") .field("reader", self.reader.reader.get_ref()) .finish() } } impl BufferedReader for BufferedReaderBzip { fn data(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data(amount); } fn data_hard(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_hard(amount); } fn data_eof(&mut self) -> Result<&[u8], io::Error> { return self.reader.data_eof(); } fn consume(&mut self, amount: usize) -> &[u8] { return self.reader.consume(amount); } fn data_consume(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_consume(amount); } fn data_consume_hard(&mut self, amount: usize) -> Result<&[u8], io::Error> { return self.reader.data_consume_hard(amount); } fn read_be_u16(&mut self) -> Result { return self.reader.read_be_u16(); } fn read_be_u32(&mut self) -> Result { return self.reader.read_be_u32(); } fn steal(&mut self, amount: usize) -> Result, io::Error> { return self.reader.steal(amount); } fn steal_eof(&mut self) -> Result, io::Error> { return self.reader.steal_eof(); } fn into_inner<'b>(self: Box) -> Option> where Self: 'b { // Strip the outer box. Some(Box::new((*self).reader.reader.into_inner())) } }