Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fix CI #2644

Merged
merged 3 commits into from Sep 15, 2022
Merged

Fix CI #2644

Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/chunks.rs
Expand Up @@ -77,7 +77,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 chunk_len = usize::from(!self.items.is_empty());
let (lower, upper) = self.stream.size_hint();
let lower = (lower / self.cap).saturating_add(chunk_len);
let upper = match upper {
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/filter.rs
Expand Up @@ -93,7 +93,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let pending_len = if self.pending_item.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending_item.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/filter_map.rs
Expand Up @@ -87,7 +87,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let pending_len = if self.pending.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/peek.rs
Expand Up @@ -204,7 +204,7 @@ impl<S: Stream> Stream for Peekable<S> {
}

fn size_hint(&self) -> (usize, Option<usize>) {
let peek_len = if self.peeked.is_some() { 1 } else { 0 };
let peek_len = usize::from(self.peeked.is_some());
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(peek_len);
let upper = match upper {
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/ready_chunks.rs
Expand Up @@ -85,7 +85,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 chunk_len = usize::from(!self.items.is_empty());
let (lower, upper) = self.stream.size_hint();
let lower = (lower / self.cap).saturating_add(chunk_len);
let upper = match upper {
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/skip_while.rs
Expand Up @@ -99,7 +99,7 @@ where
if self.done_skipping {
self.stream.size_hint()
} else {
let pending_len = if self.pending_item.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending_item.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/take_while.rs
Expand Up @@ -91,7 +91,7 @@ where
return (0, Some(0));
}

let pending_len = if self.pending_item.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending_item.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/stream/then.rs
Expand Up @@ -78,7 +78,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let future_len = if self.future.is_some() { 1 } else { 0 };
let future_len = usize::from(self.future.is_some());
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(future_len);
let upper = match upper {
Expand Down
4 changes: 2 additions & 2 deletions futures-util/src/stream/stream/zip.rs
Expand Up @@ -102,8 +102,8 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let queued1_len = if self.queued1.is_some() { 1 } else { 0 };
let queued2_len = if self.queued2.is_some() { 1 } else { 0 };
let queued1_len = usize::from(self.queued1.is_some());
let queued2_len = usize::from(self.queued2.is_some());
let (stream1_lower, stream1_upper) = self.stream1.size_hint();
let (stream2_lower, stream2_upper) = self.stream2.size_hint();

Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/and_then.rs
Expand Up @@ -71,7 +71,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let future_len = if self.future.is_some() { 1 } else { 0 };
let future_len = usize::from(self.future.is_some());
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(future_len);
let upper = match upper {
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/or_else.rs
Expand Up @@ -75,7 +75,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let future_len = if self.future.is_some() { 1 } else { 0 };
let future_len = usize::from(self.future.is_some());
let (lower, upper) = self.stream.size_hint();
let lower = lower.saturating_add(future_len);
let upper = match upper {
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/try_chunks.rs
Expand Up @@ -82,7 +82,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 chunk_len = usize::from(!self.items.is_empty());
let (lower, upper) = self.stream.size_hint();
let lower = (lower / self.cap).saturating_add(chunk_len);
let upper = match upper {
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/try_filter.rs
Expand Up @@ -90,7 +90,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let pending_len = if self.pending_fut.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending_fut.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/try_filter_map.rs
Expand Up @@ -84,7 +84,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let pending_len = if self.pending.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/try_skip_while.rs
Expand Up @@ -87,7 +87,7 @@ where
}

fn size_hint(&self) -> (usize, Option<usize>) {
let pending_len = if self.pending_item.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending_item.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
2 changes: 1 addition & 1 deletion futures-util/src/stream/try_stream/try_take_while.rs
Expand Up @@ -96,7 +96,7 @@ where
return (0, Some(0));
}

let pending_len = if self.pending_item.is_some() { 1 } else { 0 };
let pending_len = usize::from(self.pending_item.is_some());
let (_, upper) = self.stream.size_hint();
let upper = match upper {
Some(x) => x.checked_add(pending_len),
Expand Down
4 changes: 2 additions & 2 deletions futures/tests/async_await_macros.rs
Expand Up @@ -352,14 +352,14 @@ fn join_size() {
let ready = future::ready(0i32);
join!(ready)
};
assert_eq!(mem::size_of_val(&fut), 16);
assert_eq!(mem::size_of_val(&fut), 12);

let fut = async {
let ready1 = future::ready(0i32);
let ready2 = future::ready(0i32);
join!(ready1, ready2)
};
assert_eq!(mem::size_of_val(&fut), 28);
assert_eq!(mem::size_of_val(&fut), 20);
}

#[test]
Expand Down