@@ -233,12 +233,7 @@ where
233233 R : Send ,
234234 F : Fn ( Vec < T > ) -> Result < Vec < R > > + Send + Sync ,
235235{
236- if config. parallel {
237- // For parallel processing, we'd use threading (simplified here)
238- batch_in_chunks ( items, config. chunk_size , processor)
239- } else {
240- batch_in_chunks ( items, config. chunk_size , processor)
241- }
236+ batch_in_chunks ( items, config. chunk_size , processor)
242237}
243238
244239/// Configuration for batch operations
@@ -345,7 +340,10 @@ impl OperationBuilder {
345340 run_with_timeout_and_retry ( & retry, timeout, operation)
346341 }
347342 ( Some ( retry) , None ) => retry_with_backoff ( & retry, operation) ,
348- ( None , Some ( timeout) ) => with_timeout ( timeout, || operation ( ) ) ,
343+ ( None , Some ( timeout) ) => {
344+ let op = || operation ( ) ;
345+ with_timeout ( timeout, op)
346+ } ,
349347 ( None , None ) => operation ( ) ,
350348 }
351349 }
@@ -389,7 +387,7 @@ impl OperationContext {
389387 self . start_time . elapsed ( )
390388 }
391389
392- pub fn increment_retry ( & mut self ) {
390+ pub const fn increment_retry ( & mut self ) {
393391 self . retry_count += 1 ;
394392 }
395393}
0 commit comments