do not ignore pipeline errors

This commit is contained in:
2020-03-07 10:16:29 +01:00
parent 2a2810a3aa
commit 0223f24fa5

View File

@@ -180,10 +180,10 @@ async fn transcode(src: &Path, dest: &Path) -> Result<(), Error> {
}
})
.take_while(|e| {
if let Ok(true) = e {
futures::future::ready(true)
} else {
if let Ok(false) = e {
futures::future::ready(false)
} else {
futures::future::ready(true)
}
})
.try_for_each(|_| futures::future::ready(Ok(())))