Skip to content

Commit

Permalink
Fix CI (#2644)
Browse files Browse the repository at this point in the history
  • Loading branch information
Xaeroxe committed Sep 15, 2022
1 parent 67462f7 commit 9a481b0
Show file tree
Hide file tree
Showing 17 changed files with 19 additions and 19 deletions.
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

0 comments on commit 9a481b0

Please sign in to comment.