diff --git a/futures/tests/async_await_macros.rs b/futures/tests/async_await_macros.rs index 82a617f2c..e87a5bf05 100644 --- a/futures/tests/async_await_macros.rs +++ b/futures/tests/async_await_macros.rs @@ -321,8 +321,7 @@ fn stream_select() { assert_eq!(endless_ones.next().await, Some(1)); assert_eq!(endless_ones.next().await, Some(1)); - let mut finite_list = - stream_select!(stream::iter(vec![1].into_iter()), stream::iter(vec![1].into_iter())); + let mut finite_list = stream_select!(stream::iter(vec![1]), stream::iter(vec![1])); assert_eq!(finite_list.next().await, Some(1)); assert_eq!(finite_list.next().await, Some(1)); assert_eq!(finite_list.next().await, None); diff --git a/futures/tests/stream_select_all.rs b/futures/tests/stream_select_all.rs index fdeb7b997..12a993667 100644 --- a/futures/tests/stream_select_all.rs +++ b/futures/tests/stream_select_all.rs @@ -79,8 +79,7 @@ fn works_1() { #[test] fn clear() { - let mut tasks = - select_all(vec![stream::iter(vec![1].into_iter()), stream::iter(vec![2].into_iter())]); + let mut tasks = select_all(vec![stream::iter(vec![1]), stream::iter(vec![2])]); assert_eq!(block_on(tasks.next()), Some(1)); assert!(!tasks.is_empty()); @@ -88,7 +87,7 @@ fn clear() { tasks.clear(); assert!(tasks.is_empty()); - tasks.push(stream::iter(vec![3].into_iter())); + tasks.push(stream::iter(vec![3])); assert!(!tasks.is_empty()); tasks.clear();