Add config option to switch to unstable liblzma fork

Author: xbjfk

Cargo.toml

@@ -41,10 +41,14 @@ libzstd = { package = "zstd", version = "0.13.1", optional = true, default-featu
 memchr = "2"
 pin-project-lite = "0.2"
 tokio = { version = "1.24.2", optional = true, default-features = false }
-xz2 = { version = "0.1.6", optional = true }
 zstd-safe = { version = "7", optional = true, default-features = false }
 deflate64 = { version = "0.1.5", optional = true }
 
+[target.'cfg(not(async_compression_unstable_liblzma_fork))'.dependencies]
+xz2 = { version = "0.1.6", optional = true }
+[target.'cfg(async_compression_unstable_liblzma_fork)'.dependencies]
+xz2 = { package = "liblzma", version = "0.3.2", optional = true }
+
 [dev-dependencies]
 bytes = "1"
 futures = "0.3.5"
@@ -103,3 +107,6 @@ required-features = ["zlib", "tokio"]
 [[example]]
 name = "zstd_gzip"
 required-features = ["zstd", "gzip", "tokio"]
+
+[lints.rust]
+unexpected_cfgs = { level = "warn", check-cfg = ['cfg(async_compression_unstable_liblzma_fork)'] }

src/codec/xz2/decoder.rs

@@ -1,5 +1,8 @@
 use std::{fmt, io};
 
+#[cfg(async_compression_unstable_liblzma_fork)]
+use liblzma::stream::{Action, Status, Stream};
+#[cfg(not(async_compression_unstable_liblzma_fork))]
 use xz2::stream::{Action, Status, Stream};
 
 use crate::{codec::Decode, util::PartialBuffer};

src/codec/xz2/encoder.rs

@@ -1,5 +1,8 @@
 use std::{fmt, io};
 
+#[cfg(async_compression_unstable_liblzma_fork)]
+use liblzma::stream::{Action, Check, LzmaOptions, Status, Stream};
+#[cfg(not(async_compression_unstable_liblzma_fork))]
 use xz2::stream::{Action, Check, LzmaOptions, Status, Stream};
 
 use crate::{

tests/utils/algos.rs

@@ -169,14 +169,22 @@ algos! {
             pub use crate::utils::impls::sync::to_vec;
 
             pub fn compress(bytes: &[u8]) -> Vec<u8> {
+                #[cfg(not(async_compression_unstable_liblzma_fork))]
                 use xz2::bufread::XzEncoder;
 
+                #[cfg(async_compression_unstable_liblzma_fork)]
+                use liblzma::bufread::XzEncoder;
+
                 to_vec(XzEncoder::new(bytes, 0))
             }
 
             pub fn decompress(bytes: &[u8]) -> Vec<u8> {
+                #[cfg(not(async_compression_unstable_liblzma_fork))]
                 use xz2::bufread::XzDecoder;
 
+                #[cfg(async_compression_unstable_liblzma_fork)]
+                use liblzma::bufread::XzDecoder;
+
                 to_vec(XzDecoder::new(bytes))
             }
         }
@@ -187,8 +195,17 @@ algos! {
             pub use crate::utils::impls::sync::to_vec;
 
             pub fn compress(bytes: &[u8]) -> Vec<u8> {
-                use xz2::bufread::XzEncoder;
-                use xz2::stream::{LzmaOptions, Stream};
+                #[cfg(not(async_compression_unstable_liblzma_fork))]
+                use xz2::{
+                    bufread::XzEncoder,
+                    stream::{LzmaOptions, Stream},
+                };
+
+                #[cfg(async_compression_unstable_liblzma_fork)]
+                use liblzma::{
+                    bufread::XzEncoder,
+                    stream::{LzmaOptions, Stream},
+                };
 
                 to_vec(XzEncoder::new_stream(
                     bytes,
@@ -197,8 +214,17 @@ algos! {
             }
 
             pub fn decompress(bytes: &[u8]) -> Vec<u8> {
-                use xz2::bufread::XzDecoder;
-                use xz2::stream::Stream;
+                #[cfg(not(async_compression_unstable_liblzma_fork))]
+                use xz2::{
+                    bufread::XzDecoder,
+                    stream::Stream,
+                };
+
+                #[cfg(async_compression_unstable_liblzma_fork)]
+                use liblzma::{
+                    bufread::XzDecoder,
+                    stream::Stream,
+                };
 
                 to_vec(XzDecoder::new_stream(
                     bytes,