We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 52f31c8 commit 9db797eCopy full SHA for 9db797e
1 file changed
storage/src/qmdb/sync/gaps.rs
@@ -40,15 +40,15 @@ pub fn find_next<'a, F: Family>(
40
let mut fetched_ops_iter = fetched_operations
41
.iter()
42
.map(|(&start_loc, &operation_count)| {
43
- let end_loc = start_loc.checked_add(operation_count).unwrap();
+ let end_loc = start_loc.checked_add(operation_count).unwrap_or(range.end);
44
start_loc..end_loc
45
})
46
.peekable();
47
48
let mut outstanding_reqs_iter = outstanding_requests
49
.into_iter()
50
.map(|&start_loc| {
51
- let end_loc = start_loc.checked_add(fetch_batch_size.get()).unwrap();
+ let end_loc = start_loc.checked_add(fetch_batch_size.get()).unwrap_or(range.end);
52
53
54
0 commit comments