- assertFalse(reader.hasNext());
- writer.commit(i);
- assertTrue(reader.hasNext());
- Indexed<TestEntry> entry;
- entry = reader.next();
- assertEquals(i, entry.index());
- assertEquals(32, entry.entry().bytes().length);
- reader.reset(i);
- entry = reader.next();
- assertEquals(i, entry.index());
- assertEquals(32, entry.entry().bytes().length);
- }
- }
- }
-
- // Same as testWriteReadCommittedEntries(), but does not use hasNext() but checks whether an exception is thrown
- @Test
- public void testWriteReadCommittedEntriesException() throws Exception {
- try (Journal<TestEntry> journal = createJournal()) {
- JournalWriter<TestEntry> writer = journal.writer();
- JournalReader<TestEntry> reader = journal.openReader(1, JournalReader.Mode.COMMITS);
-
- for (int i = 1; i <= entriesPerSegment * 5; i++) {
- writer.append(ENTRY);
- assertThrows(NoSuchElementException.class, reader::next);