| //! Adaptors between compression crates and Rust's modern asynchronous IO types. |
| //! |
| |
| //! # Feature Organization |
| //! |
| //! This crate is divided up along two axes, which can each be individually selected via Cargo |
| //! features. |
| //! |
| //! All features are disabled by default, you should enable just the ones you need from the lists |
| //! below. |
| //! |
| //! If you want to pull in everything there are three group features defined: |
| //! |
| |
| //! Feature | Does |
| //! ---------|------ |
| //! `all` | Activates all implementations and algorithms. |
| //! `all-implementations` | Activates all implementations, needs to be paired with a selection of algorithms |
| //! `all-algorithms` | Activates all algorithms, needs to be paired with a selection of implementations |
| //! |
| |
| //! ## IO implementation |
| //! |
| //! The first division is which underlying asynchronous IO trait will be wrapped, these are |
| //! available as separate features that have corresponding top-level modules: |
| //! |
| |
| //! Feature | Type |
| //! ---------|------ |
| // TODO: Kill rustfmt on this section, `#![rustfmt::skip::attributes(cfg_attr)]` should do it, but |
| // that's unstable |
| # | [`futures::io::AsyncBufRead`](futures_io::AsyncBufRead), [`futures::io::AsyncWrite`](futures_io::AsyncWrite)" |
| )] |
| #![cfg_attr( |
| not(feature = "futures-io"), |
| doc = "`futures-io` (*inactive*) | `futures::io::AsyncBufRead`, `futures::io::AsyncWrite`" |
| )] |
| # | [`tokio::io::AsyncBufRead`](::tokio::io::AsyncBufRead), [`tokio::io::AsyncWrite`](::tokio::io::AsyncWrite)" |
| )] |
| #![cfg_attr( |
| not(feature = "tokio"), |
| doc = "`tokio` (*inactive*) | `tokio::io::AsyncBufRead`, `tokio::io::AsyncWrite`" |
| )] |
| //! |
| |
| //! ## Compression algorithm |
| //! |
| //! The second division is which compression schemes to support, there are currently a few |
| //! available choices, these determine which types will be available inside the above modules: |
| //! |
| |
| //! Feature | Types |
| //! ---------|------ |
| #, [`BrotliDecoder`](?search=BrotliDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "brotli"), |
| doc = "`brotli` (*inactive*) | `BrotliEncoder`, `BrotliDecoder`" |
| )] |
| #, [`BzDecoder`](?search=BzDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "bzip2"), |
| doc = "`bzip2` (*inactive*) | `BzEncoder`, `BzDecoder`" |
| )] |
| #, [`DeflateDecoder`](?search=DeflateDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "deflate"), |
| doc = "`deflate` (*inactive*) | `DeflateEncoder`, `DeflateDecoder`" |
| )] |
| #, [`GzipDecoder`](?search=GzipDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "gzip"), |
| doc = "`gzip` (*inactive*) | `GzipEncoder`, `GzipDecoder`" |
| )] |
| #, [`LzmaDecoder`](?search=LzmaDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "lzma"), |
| doc = "`lzma` (*inactive*) | `LzmaEncoder`, `LzmaDecoder`" |
| )] |
| #, [`XzDecoder`](?search=XzDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "xz"), |
| doc = "`xz` (*inactive*) | `XzEncoder`, `XzDecoder`" |
| )] |
| #, [`ZlibDecoder`](?search=ZlibDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "zlib"), |
| doc = "`zlib` (*inactive*) | `ZlibEncoder`, `ZlibDecoder`" |
| )] |
| #, [`ZstdDecoder`](?search=ZstdDecoder)" |
| )] |
| #![cfg_attr( |
| not(feature = "zstd"), |
| doc = "`zstd` (*inactive*) | `ZstdEncoder`, `ZstdDecoder`" |
| )] |
| #" |
| )] |
| #![cfg_attr( |
| not(feature = "deflate64"), |
| doc = "`deflate64` (*inactive*) | (encoder not implemented), `Deflate64Decoder`" |
| )] |
| //! |
| |
| #![cfg_attr(docsrs, feature(doc_auto_cfg, doc_cfg))] |
| #![warn( |
| missing_docs, |
| rust_2018_idioms, |
| missing_copy_implementations, |
| missing_debug_implementations |
| )] |
| #![cfg_attr(not(all), allow(unused))] |
| |
| #[cfg(any(feature = "bzip2", feature = "flate2", feature = "xz2"))] |
| use std::convert::TryInto; |
| |
| #[macro_use] |
| mod macros; |
| mod codec; |
| |
| #[cfg(feature = "futures-io")] |
| pub mod futures; |
| #[cfg(feature = "tokio")] |
| pub mod tokio; |
| |
| mod unshared; |
| mod util; |
| |
| #[cfg(feature = "brotli")] |
| pub mod brotli; |
| #[cfg(feature = "zstd")] |
| pub mod zstd; |
| |
| /// Level of compression data should be compressed with. |
| #[non_exhaustive] |
| #[derive(Clone, Copy, Debug)] |
| pub enum Level { |
| /// Fastest quality of compression, usually produces bigger size. |
| Fastest, |
| |
| /// Best quality of compression, usually produces the smallest size. |
| Best, |
| |
| /// Default quality of compression defined by the selected compression algorithm. |
| Default, |
| |
| /// Precise quality based on the underlying compression algorithms' qualities. The |
| /// interpretation of this depends on the algorithm chosen and the specific implementation |
| /// backing it. Qualities are implicitly clamped to the algorithm's maximum. |
| Precise(i32), |
| } |
| |
| impl Level { |
| #[cfg(feature = "brotli")] |
| fn into_brotli( |
| self, |
| mut params: ::brotli::enc::backward_references::BrotliEncoderParams, |
| ) -> ::brotli::enc::backward_references::BrotliEncoderParams { |
| match self { |
| Self::Fastest => params.quality = 0, |
| Self::Best => params.quality = 11, |
| Self::Precise(quality) => params.quality = quality.clamp(0, 11), |
| Self::Default => (), |
| } |
| |
| params |
| } |
| |
| #[cfg(feature = "bzip2")] |
| fn into_bzip2(self) -> bzip2::Compression { |
| let fastest = bzip2::Compression::fast(); |
| let best = bzip2::Compression::best(); |
| |
| match self { |
| Self::Fastest => fastest, |
| Self::Best => best, |
| Self::Precise(quality) => bzip2::Compression::new( |
| quality |
| .try_into() |
| .unwrap_or(0) |
| .clamp(fastest.level(), best.level()), |
| ), |
| Self::Default => bzip2::Compression::default(), |
| } |
| } |
| |
| #[cfg(feature = "flate2")] |
| fn into_flate2(self) -> flate2::Compression { |
| let fastest = flate2::Compression::fast(); |
| let best = flate2::Compression::best(); |
| |
| match self { |
| Self::Fastest => fastest, |
| Self::Best => best, |
| Self::Precise(quality) => flate2::Compression::new( |
| quality |
| .try_into() |
| .unwrap_or(0) |
| .clamp(fastest.level(), best.level()), |
| ), |
| Self::Default => flate2::Compression::default(), |
| } |
| } |
| |
| #[cfg(feature = "zstd")] |
| fn into_zstd(self) -> i32 { |
| let (fastest, best) = libzstd::compression_level_range().into_inner(); |
| match self { |
| Self::Fastest => fastest, |
| Self::Best => best, |
| Self::Precise(quality) => quality.clamp(fastest, best), |
| Self::Default => libzstd::DEFAULT_COMPRESSION_LEVEL, |
| } |
| } |
| |
| #[cfg(feature = "xz2")] |
| fn into_xz2(self) -> u32 { |
| match self { |
| Self::Fastest => 0, |
| Self::Best => 9, |
| Self::Precise(quality) => quality.try_into().unwrap_or(0).min(9), |
| Self::Default => 5, |
| } |
| } |
| } |