erpc_metrics/
utils.rs

1
2
3
4
5
6
7
8
9
10
use tokio::io::AsyncWriteExt;

/// Decompress given compressed slice of xz bytes
pub(crate) async fn decompress_xz(data: &[u8]) -> anyhow::Result<Vec<u8>> {
    let mut decoder =
        async_compression::tokio::write::XzDecoder::new(Vec::new());
    decoder.write_all(data).await?;
    decoder.shutdown().await?;
    Ok(decoder.into_inner())
}