don't import debug
This commit is contained in:
parent
5d1fb11f2a
commit
4ce98de0e1
|
|
@ -6,7 +6,6 @@ use tokio::{
|
||||||
io::{self, AsyncWriteExt},
|
io::{self, AsyncWriteExt},
|
||||||
sync::mpsc,
|
sync::mpsc,
|
||||||
};
|
};
|
||||||
use tracing::debug;
|
|
||||||
use walkdir::WalkDir;
|
use walkdir::WalkDir;
|
||||||
|
|
||||||
use crate::config;
|
use crate::config;
|
||||||
|
|
@ -87,9 +86,10 @@ impl Disk {
|
||||||
|
|
||||||
// receive chunks and save them to file
|
// receive chunks and save them to file
|
||||||
while let Some(chunk) = rx.recv().await {
|
while let Some(chunk) = rx.recv().await {
|
||||||
debug!("writing chunk to disk (length: {})", chunk.len());
|
tracing::debug!(length = chunk.len(), "writing chunk to disk");
|
||||||
if let Err(err) = file.write_all(&chunk).await {
|
if let Err(err) = file.write_all(&chunk).await {
|
||||||
tracing::error!(%err, "error while writing file to disk");
|
tracing::error!(%err, "error while writing file to disk");
|
||||||
|
break;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue