aboutsummaryrefslogtreecommitdiff
path: root/tests/stream_select_all.rs
diff options
context:
space:
mode:
Diffstat (limited to 'tests/stream_select_all.rs')
-rw-r--r--tests/stream_select_all.rs23
1 files changed, 16 insertions, 7 deletions
diff --git a/tests/stream_select_all.rs b/tests/stream_select_all.rs
index eb711dd..411cb73 100644
--- a/tests/stream_select_all.rs
+++ b/tests/stream_select_all.rs
@@ -1,12 +1,11 @@
-use futures::channel::mpsc;
-use futures::executor::block_on_stream;
-use futures::future::{self, FutureExt};
-use futures::stream::{self, select_all, FusedStream, SelectAll, StreamExt};
-use futures::task::Poll;
-use futures_test::task::noop_context;
-
+#[cfg(feature = "alloc")] // stream::SelectAll
#[test]
fn is_terminated() {
+ use futures::future::{self, FutureExt};
+ use futures::stream::{FusedStream, SelectAll, StreamExt};
+ use futures::task::Poll;
+ use futures_test::task::noop_context;
+
let mut cx = noop_context();
let mut tasks = SelectAll::new();
@@ -30,8 +29,12 @@ fn is_terminated() {
assert_eq!(tasks.is_terminated(), true);
}
+#[cfg(feature = "executor")] // executor::
#[test]
fn issue_1626() {
+ use futures::executor::block_on_stream;
+ use futures::stream;
+
let a = stream::iter(0..=2);
let b = stream::iter(10..=14);
@@ -48,8 +51,14 @@ fn issue_1626() {
assert_eq!(s.next(), None);
}
+#[cfg(all(feature = "alloc", feature = "std"))] // channel::mpsc
+#[cfg(feature = "executor")] // executor::
#[test]
fn works_1() {
+ use futures::channel::mpsc;
+ use futures::executor::block_on_stream;
+ use futures::stream::select_all;
+
let (a_tx, a_rx) = mpsc::unbounded::<u32>();
let (b_tx, b_rx) = mpsc::unbounded::<u32>();
let (c_tx, c_rx) = mpsc::unbounded::<u32>();