diff options
Diffstat (limited to 'src/test/java/com/amazon/carbonado/cursor')
| -rw-r--r-- | src/test/java/com/amazon/carbonado/cursor/TestCursors.java | 40 |
1 files changed, 40 insertions, 0 deletions
diff --git a/src/test/java/com/amazon/carbonado/cursor/TestCursors.java b/src/test/java/com/amazon/carbonado/cursor/TestCursors.java index a6c25aa..79a10e8 100644 --- a/src/test/java/com/amazon/carbonado/cursor/TestCursors.java +++ b/src/test/java/com/amazon/carbonado/cursor/TestCursors.java @@ -113,6 +113,26 @@ public class TestCursors extends TestCase { compareElements(c);
c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 6);
compareElements(c);
+
+ // call skip on cursor
+ c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 2);
+ assertEquals(1, c.skipNext(1));
+ compareElements(c, 4, 5);
+ c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 2);
+ assertEquals(2, c.skipNext(2));
+ compareElements(c, 5);
+ c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 2);
+ assertEquals(3, c.skipNext(3));
+ compareElements(c);
+ c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 2);
+ assertEquals(3, c.skipNext(4));
+ compareElements(c);
+ c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 100);
+ assertEquals(0, c.skipNext(4));
+ compareElements(c);
+ c = new SkipCursor<Element>(createElements(1, 2, 3, 4, 5), 0);
+ assertEquals(4, c.skipNext(4));
+ compareElements(c, 5);
}
public void testLimit() throws Exception {
@@ -136,6 +156,26 @@ public class TestCursors extends TestCase { compareElements(c, 1, 2, 3, 4, 5);
c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 6);
compareElements(c, 1, 2, 3, 4, 5);
+
+ // call skip on cursor
+ c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 3);
+ assertEquals(1, c.skipNext(1));
+ compareElements(c, 2, 3);
+ c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 3);
+ assertEquals(2, c.skipNext(2));
+ compareElements(c, 3);
+ c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 3);
+ assertEquals(3, c.skipNext(3));
+ compareElements(c);
+ c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 3);
+ assertEquals(3, c.skipNext(4));
+ compareElements(c);
+ c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 100);
+ assertEquals(4, c.skipNext(4));
+ compareElements(c, 5);
+ c = new LimitCursor<Element>(createElements(1, 2, 3, 4, 5), 0);
+ assertEquals(0, c.skipNext(4));
+ compareElements(c);
}
public void testUnion() throws Exception {
|