We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent d13f77e commit 0a0ea51Copy full SHA for 0a0ea51
futures-util/src/stream/select_all.rs
@@ -1,6 +1,7 @@
1
//! An unbounded set of streams
2
3
use core::fmt::{self, Debug};
4
+use core::iter::FromIterator;
5
use core::pin::Pin;
6
7
use futures_core::{Poll, Stream, FusedStream};
@@ -121,3 +122,9 @@ pub fn select_all<I>(streams: I) -> SelectAll<I::Item>
121
122
123
set
124
}
125
+
126
+impl<St: Stream + Unpin> FromIterator<St> for SelectAll<St> {
127
+ fn from_iter<T: IntoIterator<Item = St>>(iter: T) -> Self {
128
+ select_all(iter)
129
+ }
130
+}
0 commit comments