use miniz_oxide::{    inflate::core::DecompressorOxide,    inflate::{        core::inflate_flags::{            TINFL_FLAG_HAS_MORE_INPUT, TINFL_FLAG_PARSE_ZLIB_HEADER, TINFL_FLAG_USING_NON_WRAPPING_OUTPUT_BUF,        },        TINFLStatus,    },}; #[derive(thiserror::Error, Debug)]pub enum Error {    #[error("Could not write all bytes when decompressing content")]    WriteInflated(#[from] std::io::Error),    #[error("Could not decode zip stream, status was '{0:?}'")]    Inflate(miniz_oxide::inflate::TINFLStatus),} /// Decompress a few bytes of a zlib stream without allocationpub struct Inflate {    state: DecompressorOxide,    pub is_done: bool,} impl Default for Inflate {    fn default() -> Self {        Inflate {            state: DecompressorOxide::default(),            is_done: false,        }    }} impl Inflate {    /// Run the decompressor exactly once. Cannot be run mutliple times    pub fn once(        &mut self,        input: &[u8],        out: &mut [u8],        parse_header: bool,    ) -> Result<(TINFLStatus, usize, usize), Error> {        let (status, in_consumed, out_consumed) = miniz_oxide::inflate::core::decompress(            &mut self.state,            input,            out,            0,            if parse_header { TINFL_FLAG_PARSE_ZLIB_HEADER } else { 0 }                | TINFL_FLAG_HAS_MORE_INPUT                | TINFL_FLAG_USING_NON_WRAPPING_OUTPUT_BUF,        );         use miniz_oxide::inflate::TINFLStatus::*;        match status {            Failed | FailedCannotMakeProgress | BadParam | Adler32Mismatch => return Err(Error::Inflate(status)),            HasMoreOutput | NeedsMoreInput => {}            Done => {                self.is_done = true;            }        };        Ok((status, in_consumed, out_consumed))    }} pub mod stream;