···

       
404
       
404
       
 
       
        // let mut ts = CLOCK.now();

     

       
405
       
405
       
 
       
        let mut current_item_count = 0;

     

       
406
       
406
       
 
       
        let map_block = move |(key, val)| {

     

       
407
       
407
       
-
       
            if current_item_count > max_items {

     

       
407
       
407
       
+
       
            if current_item_count >= max_items {

     

       
408
       
408
       
 
       
                return Ok(None);

     

       
409
       
409
       
 
       
            }

     

       
410
       
410
       
 
       
            let mut key_reader = Cursor::new(key);

     
···

       
441
       
441
       
 
       
            .map_while(move |res| res.map_err(AppError::from).and_then(map_block).transpose())

     

       
442
       
442
       
 
       
            .collect_vec();

     

       
443
       
443
       
 
       


     

       
444
       
444
       
-
       
        tracing::info!("got blocks with size {}", blocks.len());

     

       
444
       
444
       
+
       
        tracing::info!(

     

       
445
       
445
       
+
       
            "got blocks with size {}, item count {current_item_count}",

     

       
446
       
446
       
+
       
            blocks.len()

     

       
447
       
447
       
+
       
        );

     

       
445
       
448
       
 
       


     

       
446
       
449
       
 
       
        Either::Left(blocks.into_iter().rev().flatten().flatten())

     

       
447
       
450
       
 
       
    }