use crate::zlib::stream::InflateReader; use std::io::BufReader; pub enum Reader<'a> { File(usize, InflateReader>), Buffer(&'a [u8]), } impl<'a> Reader<'a> { pub fn from_read(header_size: usize, file: std::fs::File) -> Reader<'a> { Reader::File(header_size, InflateReader::from_read(std::io::BufReader::new(file))) } pub fn from_data(header_size: usize, data: &'a [u8]) -> Reader<'a> { Reader::Buffer(&data[header_size..]) } } impl<'a> std::io::Read for Reader<'a> { fn read(&mut self, buf: &mut [u8]) -> std::io::Result { match self { Reader::Buffer(data) => data.read(buf), Reader::File(header_size_left, r) => { if *header_size_left == 0 { r.read(buf) } else { // We must assure we return at least one byte - otherwise it's considered EOF while *header_size_left != 0 { let bytes_to_read = buf.len().min(*header_size_left); r.read_exact(&mut buf[..bytes_to_read])?; *header_size_left -= bytes_to_read; } r.read(buf) } } } } }