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 Jun 23, 2021
1 parent f5e362c commit ff7a68f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 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 Down

0 comments on commit ff7a68f

Please sign in to comment.