We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 9f40e6c commit 74ff5a1Copy full SHA for 74ff5a1
futures-util/src/stream/select_all.rs
@@ -61,7 +61,7 @@ impl<St: Stream + Unpin> SelectAll<St> {
61
/// function will not call `poll` on the submitted stream. The caller must
62
/// ensure that `SelectAll::poll` is called in order to receive task
63
/// notifications.
64
- pub fn push(&mut self, stream: St) {
+ pub fn push(&self, stream: St) {
65
self.inner.push(stream.into_future());
66
}
67
@@ -119,7 +119,7 @@ pub fn select_all<I>(streams: I) -> SelectAll<I::Item>
119
where I: IntoIterator,
120
I::Item: Stream + Unpin
121
{
122
- let mut set = SelectAll::new();
+ let set = SelectAll::new();
123
124
for stream in streams {
125
set.push(stream);
0 commit comments