forked from mirror/async-std
Recovered comments
This commit is contained in:
parent
83afbab2ef
commit
fb567a3a09
3 changed files with 3 additions and 0 deletions
|
@ -24,6 +24,7 @@ where
|
||||||
.take_while(|elem| {
|
.take_while(|elem| {
|
||||||
elem.is_some() || {
|
elem.is_some() || {
|
||||||
found_none = true;
|
found_none = true;
|
||||||
|
// Stop processing the stream on `None`
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
|
@ -48,6 +48,7 @@ where
|
||||||
.take_while(|elem| {
|
.take_while(|elem| {
|
||||||
elem.is_some() || {
|
elem.is_some() || {
|
||||||
found_none = true;
|
found_none = true;
|
||||||
|
// Stop processing the stream on `None`
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
|
@ -43,6 +43,7 @@ where
|
||||||
.take_while(|elem| {
|
.take_while(|elem| {
|
||||||
elem.is_some() || {
|
elem.is_some() || {
|
||||||
found_none = true;
|
found_none = true;
|
||||||
|
// Stop processing the stream on error
|
||||||
false
|
false
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
|
|
Loading…
Reference in a new issue