Skip to content

Commit

Permalink
decompression: propagate size_hint when body is identity
Browse files Browse the repository at this point in the history
  • Loading branch information
seanmonstar committed Aug 6, 2024
1 parent 24b6b73 commit fb30f7c
Showing 1 changed file with 8 additions and 1 deletion.
9 changes: 8 additions & 1 deletion tower-http/src/decompression/body.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ use async_compression::tokio::bufread::ZlibDecoder;
use async_compression::tokio::bufread::ZstdDecoder;
use bytes::{Buf, Bytes};
use http::HeaderMap;
use http_body::Body;
use http_body::{Body, SizeHint};
use pin_project_lite::pin_project;
use std::task::Context;
use std::{
Expand Down Expand Up @@ -326,6 +326,13 @@ where
BodyInnerProj::Zstd { inner } => match inner.0 {},
}
}

fn size_hint(&self) -> SizeHint {
match self.inner {
BodyInner::Identity { ref inner } => inner.size_hint(),
_ => SizeHint::default(),
}
}
}

#[cfg(feature = "decompression-gzip")]
Expand Down

0 comments on commit fb30f7c

Please sign in to comment.