fix: update error handling
CI / format (push) Has been cancelled
CI / test (push) Has been cancelled
CI / packaging (push) Has been cancelled

This commit is contained in:
Tien Do Nam
2026-07-13 22:01:35 +02:00
parent 3aedb1a67f
commit 596621a772
+6 -1
View File
@@ -165,10 +165,15 @@ async fn write_file_from_receiver(
let mut file = open.await?;
let mut written: u64 = 0;
while let Some(chunk) = rx.recv().await {
written += chunk.len() as u64;
if written > expected_size {
return Err(format!(
"Expected {expected_size} bytes, received at least {written}"
));
}
file.write_all(&chunk)
.await
.map_err(|e| format!("Failed to write file: {e}"))?;
written += chunk.len() as u64;
}
file.flush()
.await