mirror/async-std
2
0
Fork 1
mirror of https://github.com/async-rs/async-std.git synced 2025-04-04 15:36:40 +00:00
Code Issues Releases Wiki Activity

refacotr: Refactor match expression

Browse source
This commit is contained in:
k-nasa 2019-10-01 17:42:45 +09:00
parent 2460f35768
commit 87b272f83d
3 changed files with 11 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
src/stream/stream/filter.rs
View file

@ -36,12 +36,10 @@ where
let next = futures_core::ready!(self.as_mut().stream().poll_next(cx)); let next = futures_core::ready!(self.as_mut().stream().poll_next(cx));
match next { match next {
Some(v) => match (self.as_mut().predicate())(&v) { Some(v) if (self.as_mut().predicate())(&v) => Poll::Ready(Some(v)),
true => Poll::Ready(Some(v)), Some(_) => {
false => {
cx.waker().wake_by_ref(); cx.waker().wake_by_ref();
Poll::Pending Poll::Pending
}
}, },
None => Poll::Ready(None), None => Poll::Ready(None),
} }

6
src/stream/stream/find.rs
View file

@ -36,12 +36,10 @@ where
let item = futures_core::ready!(Pin::new(&mut *self.stream).poll_next(cx)); let item = futures_core::ready!(Pin::new(&mut *self.stream).poll_next(cx));
match item { match item {
Some(v) => match (&mut self.p)(&v) { Some(v) if (&mut self.p)(&v) => Poll::Ready(Some(v)),
true => Poll::Ready(Some(v)), Some(_) => {
false => {
cx.waker().wake_by_ref(); cx.waker().wake_by_ref();
Poll::Pending Poll::Pending
}
}, },
None => Poll::Ready(None), None => Poll::Ready(None),
} }

5
src/stream/stream/skip_while.rs
View file

@ -38,12 +38,9 @@ where
match next { match next {
Some(v) => match self.as_mut().predicate() { Some(v) => match self.as_mut().predicate() {
Some(p) => match p(&v) { Some(p) => if !p(&v) {
true => (),
false => {
*self.as_mut().predicate() = None; *self.as_mut().predicate() = None;
return Poll::Ready(Some(v)); return Poll::Ready(Some(v));
}
}, },
None => return Poll::Ready(Some(v)), None => return Poll::Ready(Some(v)),
}, },