···

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

     

       
405
       
 
       
        let mut current_item_count = 0;

     

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

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

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

     

       
408
       
 
       
            let start_timestamp = key_reader.read_varint::<u64>()?;

     

       
409
       
 
       
            // let end_timestamp = key_reader.read_varint::<u64>()?;

     
···

       
415
       
 
       
            }

     

       
416
       
 
       
            let decoder = handle::ItemDecoder::new(Cursor::new(val), start_timestamp)?;

     

       
417
       
 
       
            current_item_count += decoder.item_count();

     

       
418
       
-
       
            if current_item_count > max_items {

     

       
419
       
-
       
                return Ok(None);

     

       
420
       
-
       
            }

     

       
421
       
 
       
            // tracing::info!(

     

       
422
       
 
       
            //     "took {}ns to get block with size {}",

     

       
423
       
 
       
            //     ts.elapsed().as_nanos(),

     

···

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

     

       
405
       
 
       
        let mut current_item_count = 0;

     

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

     

       
407
       
+
       
            if current_item_count > max_items {

     

       
408
       
+
       
                return Ok(None);

     

       
409
       
+
       
            }

     

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

     

       
411
       
 
       
            let start_timestamp = key_reader.read_varint::<u64>()?;

     

       
412
       
 
       
            // let end_timestamp = key_reader.read_varint::<u64>()?;

     
···

       
418
       
 
       
            }

     

       
419
       
 
       
            let decoder = handle::ItemDecoder::new(Cursor::new(val), start_timestamp)?;

     

       
420
       
 
       
            current_item_count += decoder.item_count();

     

       
0
       
 
       

     

       
0
       
 
       

     

       
0
       
 
       

     

       
421
       
 
       
            // tracing::info!(

     

       
422
       
 
       
            //     "took {}ns to get block with size {}",

     

       
423
       
 
       
            //     ts.elapsed().as_nanos(),