diff --git a/src/algorithm/compression/zlib.rs b/src/algorithm/compression/zlib.rs index f5fbded..6670e9f 100644 --- a/src/algorithm/compression/zlib.rs +++ b/src/algorithm/compression/zlib.rs @@ -1,57 +1,3 @@ -// pub struct Zlib<'a> { -// decompressor: flate2::Decompress, -// compressor: flate2::Compress, -// input: &'a [u8], -// } - -// impl<'a> Zlib<'a> { -// pub fn new(decompressor: flate2::Decompress, input: &'a [u8]) -> Zlib<'a> { -// Zlib { -// decompressor, -// input, -// } -// } - -// pub fn into_inner(self) -> Result { -// if self.input.is_empty() { -// Ok(self.decompressor) -// } else { -// Err(std::io::Error::new( -// std::io::ErrorKind::InvalidData, -// "leftover zlib byte data", -// )) -// } -// } - -// pub fn read_u8(&mut self) -> std::io::Result { -// let mut buf = [0; 1]; -// self.read_exact(&mut buf)?; -// Ok(buf[0]) -// } -// } - -// impl<'a> Read for Zlib<'a> { -// fn read(&mut self, output: &mut [u8]) -> std::io::Result { -// let in_before = self.decompressor.total_in(); -// let out_before = self.decompressor.total_out(); -// let result = -// self.decompressor -// .decompress(self.input, output, flate2::FlushDecompress::None); -// let consumed = (self.decompressor.total_in() - in_before) as usize; -// let produced = (self.decompressor.total_out() - out_before) as usize; - -// self.input = &self.input[consumed..]; -// match result { -// Ok(flate2::Status::Ok) => Ok(produced), -// Ok(flate2::Status::BufError) => Ok(0), -// Err(error) => Err(std::io::Error::new(std::io::ErrorKind::InvalidData, error)), -// Ok(flate2::Status::StreamEnd) => Err(std::io::Error::new( -// std::io::ErrorKind::InvalidData, -// "zlib stream end", -// )), -// } -// } -// } use flate2; use crate::SshError;