@@ -1859,14 +1859,21 @@ mod shard_tests {
1859
1859
let all_items = all_items_res?;
1860
1860
assert ! ( set_compare( & true_items, & all_items) ) ;
1861
1861
1862
- // Check that the skip_lazy feature produces the expected results.
1863
- let mut unsorted_reader_skip = UnsortedShardReader :: < T1 > :: open ( tmp. path ( ) ) ;
1864
- let to_skip = ( disk_chunk_size * 3 ) + 1 ;
1865
- let skipped = unsorted_reader_skip. skip_lazy ( to_skip) ?;
1866
- assert_eq ! ( to_skip, skipped) ;
1867
- let all_items_res_skip: Result < Vec < _ > , Error > = unsorted_reader_skip. collect ( ) ;
1868
- let all_items_skip = all_items_res_skip?;
1869
- assert_eq ! ( & all_items[ to_skip..] , & all_items_skip) ;
1862
+ let check_unsorted_skip = |to_skip : usize | -> Result < ( ) , Error > {
1863
+ let mut unsorted_reader_skip = UnsortedShardReader :: < T1 > :: open ( tmp. path ( ) ) ;
1864
+ let skipped = unsorted_reader_skip. skip_lazy ( to_skip) ?;
1865
+ assert_eq ! ( to_skip, skipped) ;
1866
+ let all_items_res_skip: Result < Vec < _ > , Error > = unsorted_reader_skip. collect ( ) ;
1867
+ let all_items_skip = all_items_res_skip?;
1868
+ assert_eq ! ( & all_items[ to_skip..] , & all_items_skip) ;
1869
+ Ok ( ( ) )
1870
+ } ;
1871
+
1872
+ check_unsorted_skip ( 0 ) ?;
1873
+ check_unsorted_skip ( 1 ) ?;
1874
+ check_unsorted_skip ( disk_chunk_size) ?;
1875
+ check_unsorted_skip ( n_items) ?;
1876
+ check_unsorted_skip ( ( disk_chunk_size * 3 ) + 1 ) ?;
1870
1877
}
1871
1878
Ok ( ( ) )
1872
1879
}
0 commit comments