snappy: propage error instead of using unwrap

though very unlikely to panic, use ? operator
minhajuddin2510 · May 20, 2023 · a2f3822 · a2f3822
1 parent f1b44ba
commit a2f3822
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/src/cmd/snappy.rs b/src/cmd/snappy.rs
@@ -198,10 +198,8 @@ pub fn run(argv: &[&str]) -> CliResult<()> {
 // multi-threaded streaming snappy compression
 fn compress<R: Read, W: Write + Send + 'static>(mut src: R, dst: W, jobs: usize) -> CliResult<()> {
     let mut writer = ParCompressBuilder::<Snap>::new()
-        .num_threads(jobs)
-        .unwrap()
-        .buffer_size(gzp::BUFSIZE)
-        .unwrap()
+        .num_threads(jobs)?
+        .buffer_size(gzp::BUFSIZE)?
         .pin_threads(Some(0))
         .from_writer(dst);
     io::copy(&mut src, &mut writer)?;