min
/
breeze
1
0
Fork 0
Code Issues 2 Pull Requests Packages Projects Releases Wiki Activity

fix disk saving bug

This commit is contained in:
minish 2024-05-27 11:42:05 -04:00
parent 0a98b6b8ba
commit 7bfbe3b1fe
Signed by: min
GPG Key ID: FEECFF24EF0CE9E9
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/engine.rs
View File

@ -185,8 +185,6 @@ impl Engine {
None None
}; };
let tx: Option<&_> = tx.as_ref();
// whether or not we're gonna coalesce the data // whether or not we're gonna coalesce the data
// in order to strip the exif data at the end, // in order to strip the exif data at the end,
// instead of just sending it off to the i/o task // instead of just sending it off to the i/o task
@ -209,7 +207,9 @@ impl Engine {
// also cloning this is okay because it's a Bytes // also cloning this is okay because it's a Bytes
if !coalesce_and_strip { if !coalesce_and_strip {
debug!("sending chunk to i/o task"); debug!("sending chunk to i/o task");
tx.map(|tx| tx.send(chunk.clone())); if let Some(ref tx) = tx {
let _ = tx.send(chunk.clone()).await;
}
} }
if use_cache { if use_cache {
@ -240,14 +240,18 @@ impl Engine {
img.encoder().bytes() img.encoder().bytes()
}) })
}) { }) {
debug!("stripped exif data"); info!("stripped exif data");
data data
} else { } else {
info!("failed to strip exif data");
data data
}; };
// send what we did over to the i/o task, all in one chunk // send what we did over to the i/o task, all in one chunk
tx.map(|tx| tx.send(data.clone())); debug!("sending filled buffer to i/o task");
if let Some(ref tx) = tx {
let _ = tx.send(data.clone()).await;
}
data data
} else { } else {