vinzenz/servicepoint
0
0
Fork 0
mirror of https://github.com/cccb/servicepoint.git synced 2025-01-18 18:10:14 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

clippy changes

Browse source
This commit is contained in:
Vinzenz Schroeter 2024-05-16 23:16:05 +02:00
parent 95928ee85c
commit 972d713cf1
1 changed files with 5 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
servicepoint2/src/compression.rs
View file

@ -3,9 +3,8 @@ use std::io::{Read, Write};
#[cfg(feature = "compression_bzip2")] #[cfg(feature = "compression_bzip2")]
use bzip2::read::{BzDecoder, BzEncoder}; use bzip2::read::{BzDecoder, BzEncoder};
#[cfg(feature = "compression_zlib")]
use flate2::{FlushCompress, FlushDecompress, Status}; use flate2::{FlushCompress, FlushDecompress, Status};
#[cfg(feature = "compression_lzma")]
use lzma;
#[cfg(feature = "compression_zstd")] #[cfg(feature = "compression_zstd")]
use zstd::{Decoder as ZstdDecoder, Encoder as ZstdEncoder}; use zstd::{Decoder as ZstdDecoder, Encoder as ZstdEncoder};
@ -13,7 +12,7 @@ use crate::{CompressionCode, Payload};
pub(crate) fn into_decompressed( pub(crate) fn into_decompressed(
kind: CompressionCode, kind: CompressionCode,
mut payload: Payload, payload: Payload,
) -> Option<Payload> { ) -> Option<Payload> {
match kind { match kind {
CompressionCode::Uncompressed => Some(payload), CompressionCode::Uncompressed => Some(payload),
@ -22,7 +21,7 @@ pub(crate) fn into_decompressed(
let mut decompress = flate2::Decompress::new(true); let mut decompress = flate2::Decompress::new(true);
let mut buffer = [0u8; 10000]; let mut buffer = [0u8; 10000];
let status = match decompress.decompress(&*payload, &mut buffer, FlushDecompress::Finish) { let status = match decompress.decompress(&payload, &mut buffer, FlushDecompress::Finish) {
Err(_) => return None, Err(_) => return None,
Ok(status) => status, Ok(status) => status,
}; };
@ -44,7 +43,7 @@ pub(crate) fn into_decompressed(
} }
#[cfg(feature = "compression_lzma")] #[cfg(feature = "compression_lzma")]
CompressionCode::Lzma => { CompressionCode::Lzma => {
Some(lzma::decompress(&mut payload).unwrap()) Some(lzma::decompress(&payload).unwrap())
} }
#[cfg(feature = "compression_zstd")] #[cfg(feature = "compression_zstd")]
CompressionCode::Zstd => { CompressionCode::Zstd => {
@ -72,7 +71,7 @@ pub(crate) fn into_compressed(
let mut compress = flate2::Compress::new(flate2::Compression::fast(), true); let mut compress = flate2::Compress::new(flate2::Compression::fast(), true);
let mut buffer = [0u8; 10000]; let mut buffer = [0u8; 10000];
match compress.compress(&*payload, &mut buffer, FlushCompress::Finish).expect("compress failed") { match compress.compress(&payload, &mut buffer, FlushCompress::Finish).expect("compress failed") {
Status::Ok => panic!("buffer should be big enough"), Status::Ok => panic!("buffer should be big enough"),
Status::BufError => panic!("BufError"), Status::BufError => panic!("BufError"),
Status::StreamEnd => {} Status::StreamEnd => {}