mirror/async-std
2
0
Fork 1
mirror of https://github.com/async-rs/async-std.git synced 2025-04-23 16:56:46 +00:00
Code Issues Releases Wiki Activity

use as_mut for stream-partition

Browse source
This commit is contained in:
yjhmelody 2019-11-16 00:54:50 +08:00
parent 693a7257b8
commit a69b3a8a9e
1 changed files with 1 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/stream/stream/partition.rs
View file

@ -45,13 +45,11 @@ where
match next { match next {
Some(v) => { Some(v) => {
let mut res = this.res.take().unwrap(); let res = this.res.as_mut().unwrap();
match (this.f)(&v) { match (this.f)(&v) {
true => res.0.extend(Some(v)), true => res.0.extend(Some(v)),
false => res.1.extend(Some(v)), false => res.1.extend(Some(v)),
}; };
*this.res = Some(res);
} }
None => return Poll::Ready(this.res.take().unwrap()), None => return Poll::Ready(this.res.take().unwrap()),
} }