fix(core): write concurrent doesn't set correctly (#4816)

feat: fix write concurrent
apache · Jun 27, 2024 · 0ebb425 · 0ebb425
1 parent 3baf71e
commit 0ebb425
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/types/operator/operator_futures.rs b/core/src/types/operator/operator_futures.rs
@@ -300,7 +300,7 @@ impl<F: Future<Output = Result<()>>> FutureWrite<F> {
 
     /// Set the maximum concurrent write task amount.
     pub fn concurrent(self, v: usize) -> Self {
-        self.map(|(args, bs)| (args.with_chunk(v), bs))
+        self.map(|(args, bs)| (args.with_concurrent(v), bs))
     }
 
     /// Set the content type of option