Add callback support to chunk_stream_with and implement stream writing

1 files changed, 7 insertions, 5 deletions

diff --git a/src/chunker/context.rs b/src/chunker/context.rs
index 79254f5..b7418f0 100644
--- a/src/chunker/context.rs
+++ b/src/chunker/context.rs
@@ -3,8 +3,9 @@ use std::{collections::HashMap, env::current_dir, path::PathBuf, process::exit,
 use log::{error, warn};
 
 use crate::{
-    chunker::constants::BUTCK_STORAGE_DIR_NAME, core::hash::ChunkWriteHash, special_argument,
-    special_flag, utils::file_input_solve::parse_path_input,
+    chunker::{constants::BUTCK_STORAGE_DIR_NAME, rw::storage::hash::ChunkWriteHash},
+    special_argument, special_flag,
+    utils::file_input_solve::parse_path_input,
 };
 
 #[derive(Debug, Default)]
@@ -69,9 +70,10 @@ impl ButckContext {
 
     fn apply_stream_read(&mut self, args: &mut Vec<String>) {
         if let Some(size_str) = special_argument!(args, "-S", "--stream-read")
-            && let Ok(size) = size_str.parse::<u32>() {
-                self.stream_read = Some(size);
-            }
+            && let Ok(size) = size_str.parse::<u32>()
+        {
+            self.stream_read = Some(size);
+        }
     }
 
     fn apply_memmap_read(&mut self, args: &mut Vec<String>) -> bool {