Skip to content

Commit

Permalink
Update ref to futures crate
Browse files Browse the repository at this point in the history
  • Loading branch information
Xaeroxe committed Mar 18, 2021
1 parent 4d0f0fa commit 802e27a
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions futures/tests/macro-tests/src/main.rs
Expand Up @@ -70,17 +70,17 @@ fn main() {
let _ = block_on(async {
let endless_ints = |i| stream::iter(vec![i].into_iter().cycle()).fuse();

let mut endless_ones = futures03::stream_select!(endless_ints(1i32), stream::pending().fuse());
let mut endless_ones = futures04::stream_select!(endless_ints(1i32), stream::pending().fuse());
assert_eq!(endless_ones.next().await, Some(1));
assert_eq!(endless_ones.next().await, Some(1));

let mut finite_list = futures03::stream_select!(stream::iter(vec![1, 2, 3].into_iter()).fuse());
let mut finite_list = futures04::stream_select!(stream::iter(vec![1, 2, 3].into_iter()).fuse());
assert_eq!(finite_list.next().await, Some(1));
assert_eq!(finite_list.next().await, Some(2));
assert_eq!(finite_list.next().await, Some(3));
assert_eq!(finite_list.next().await, None);

let endless_mixed = futures03::stream_select!(endless_ints(1i32), endless_ints(2), endless_ints(3));
let endless_mixed = futures04::stream_select!(endless_ints(1i32), endless_ints(2), endless_ints(3));
// Take 100, and assert a somewhat even distribution of values.
// The fairness is randomized, but over 100 samples we should be pretty close to even.
// This test may be a bit flaky. Feel free to adjust the margins as you see fit.
Expand All @@ -97,4 +97,4 @@ fn main() {
assert!(results.iter().filter(|x| **x == 3).count() >= 29);
});

}
}

0 comments on commit 802e27a

Please sign in to comment.