diff --git a/recisdb-rs/src/io.rs b/recisdb-rs/src/io.rs index 1a086e3..b25a7c9 100644 --- a/recisdb-rs/src/io.rs +++ b/recisdb-rs/src/io.rs @@ -139,14 +139,16 @@ impl Future for AsyncInOutTriple { } // Finalize - match this.progress_tx.send(u64::MAX) { - Ok(_) => {} - Err(_) => { - // Most likely due to pressing Ctrl+C - return Poll::Ready(Err(io::Error::new( - io::ErrorKind::Interrupted, - "Ctrl+C pressed", - ))); + for _ in 1..1000000 { + match this.progress_tx.send(u64::MAX) { + Ok(_) => {} + Err(_) => { + // Most likely due to pressing Ctrl+C + return Poll::Ready(Err(io::Error::new( + io::ErrorKind::Interrupted, + "Ctrl+C pressed", + ))); + } } } info!("Flushing the buffer…"); diff --git a/recisdb-rs/src/main.rs b/recisdb-rs/src/main.rs index 4f2ea50..720e66b 100644 --- a/recisdb-rs/src/main.rs +++ b/recisdb-rs/src/main.rs @@ -30,7 +30,7 @@ fn main() { match rx.recv() { Ok(u64::MAX) => { utils::progress(&pb, file_sz); - info!("fill") + debug!("fill") } Ok(v) => { utils::progress(&pb, v);