Skip to content

Commit

Permalink
stream: Fix Chunk adapters size hints (#2611)
Browse files Browse the repository at this point in the history
  • Loading branch information
jefftt authored and taiki-e committed Aug 14, 2022
1 parent 0db9749 commit 41b9aac
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/chunks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -79,7 +79,7 @@ impl<St: Stream> Stream for Chunks<St> {
fn size_hint(&self) -> (usize, Option<usize>) {
let chunk_len = if self.items.is_empty() { 0 } else { 1 };
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(chunk_len);
let lower = (lower / self.cap).saturating_add(chunk_len);
let upper = match upper {
Some(x) => x.checked_add(chunk_len),
None => None,
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/ready_chunks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,7 @@ impl<St: Stream> Stream for ReadyChunks<St> {
fn size_hint(&self) -> (usize, Option<usize>) {
let chunk_len = if self.items.is_empty() { 0 } else { 1 };
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(chunk_len);
let lower = (lower / self.cap).saturating_add(chunk_len);
let upper = match upper {
Some(x) => x.checked_add(chunk_len),
None => None,
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/try_chunks.rs
Original file line number Diff line number Diff line change
Expand Up @@ -83,7 +83,7 @@ impl<St: TryStream> Stream for TryChunks<St> {
fn size_hint(&self) -> (usize, Option<usize>) {
let chunk_len = if self.items.is_empty() { 0 } else { 1 };
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(chunk_len);
let lower = (lower / self.cap).saturating_add(chunk_len);
let upper = match upper {
Some(x) => x.checked_add(chunk_len),
None => None,
Expand Down

0 comments on commit 41b9aac

Please sign in to comment.