Skip to content

Commit 484b80e

Browse files
committed
fix: unit tests
1 parent db7c38e commit 484b80e

File tree

1 file changed

+9
-7
lines changed

1 file changed

+9
-7
lines changed

rumqttd/src/segments/mod.rs

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -389,7 +389,7 @@ mod tests {
389389
next,
390390
Done {
391391
start: (0, 9),
392-
end: (0, 10)
392+
end: (1, 10)
393393
}
394394
);
395395
continue;
@@ -430,7 +430,7 @@ mod tests {
430430
next,
431431
Done {
432432
start: (0, 0),
433-
end: (0, 10)
433+
end: (1, 10)
434434
}
435435
);
436436

@@ -445,7 +445,7 @@ mod tests {
445445
next,
446446
Done {
447447
start: (0, 0),
448-
end: (0, 10)
448+
end: (1, 10)
449449
}
450450
);
451451

@@ -460,13 +460,14 @@ mod tests {
460460
next,
461461
Done {
462462
start: (0, 5),
463-
end: (0, 10)
463+
end: (1, 10)
464464
}
465465
);
466466

467467
// Read again after after appending again
468468
let mut out = Vec::new();
469469
let next = log.readv((0, 10), 20, &mut out).unwrap();
470+
// This should have end: (1, 10)
470471
assert_eq!(
471472
next,
472473
Done {
@@ -486,7 +487,7 @@ mod tests {
486487
next,
487488
Done {
488489
start: (0, 10),
489-
end: (0, 20)
490+
end: (1, 20)
490491
}
491492
);
492493
}
@@ -551,7 +552,7 @@ mod tests {
551552
next,
552553
Done {
553554
start: (2, 200),
554-
end: (2, 300)
555+
end: (3, 300)
555556
}
556557
);
557558
}
@@ -597,6 +598,7 @@ mod tests {
597598
end: (3, 35)
598599
}
599600
);
601+
// This should have end: (4, 40) as well
600602
let next = log.readv((3, 40), 5, &mut out).unwrap();
601603
assert_eq!(
602604
next,
@@ -645,7 +647,7 @@ mod tests {
645647
next,
646648
Done {
647649
start: (3, 30),
648-
end: (3, 40)
650+
end: (4, 40)
649651
}
650652
);
651653
}

0 commit comments

Comments
 (0)