konevsa/proxmox
1
0
Fork 0
forked from Proxmox/proxmox
Code Pull Requests Activity

compression: limit ZstdEncoder constructors to usable ones

Browse Source 
Signed-off-by: Wolfgang Bumiller <w.bumiller@proxmox.com>
This commit is contained in:
Wolfgang Bumiller 2022-04-13 09:31:56 +02:00
parent 79ac8d7344
commit f8fe8f59a6
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
proxmox-compression/src/zstd.rs
View File

@ -32,7 +32,11 @@ pub struct ZstdEncoder<'a, T> {
state: EncoderState,
}
impl<'a, T> ZstdEncoder<'a, T> {
impl<'a, T, O> ZstdEncoder<'a, T>
where
T: Stream<Item = Result<O, Error>> + Unpin,
O: Into<Bytes>,
{
/// Returns a new [ZstdEncoder] with default level 3
pub fn new(inner: T) -> Result<Self, io::Error> {
Self::with_quality(inner, 3)
@ -48,7 +52,9 @@ impl<'a, T> ZstdEncoder<'a, T> {
state: EncoderState::Reading,
})
}
}
impl<'a, T> ZstdEncoder<'a, T> {
/// Returns the wrapped [Stream]
pub fn into_inner(self) -> T {
self.inner