@Test @SuppressWarnings("OptionalGetWithoutIsPresent") public void testLoad_LargeAmountOfEvents() { int eventCount = testSubject.batchSize() + 10; testSubject.appendEvents(createEvents(eventCount)); assertEquals(eventCount, testSubject.readEvents(AGGREGATE).asStream().count()); assertEquals(eventCount - 1, testSubject.readEvents(AGGREGATE).asStream().reduce((a, b) -> b).get().getSequenceNumber()); }
public int batchSize() { return batchSize; }
BatchingEventStorageEngine extends AbstractEventStorageEngine { public int batchSize() { return batchSize; } }
BatchingEventStorageEngine extends AbstractEventStorageEngine { public int batchSize() { return batchSize; } protected  BatchingEventStorageEngine(Builder builder); }
BatchingEventStorageEngine extends AbstractEventStorageEngine { public int batchSize() { return batchSize; } protected  BatchingEventStorageEngine(Builder builder); int batchSize(); }
BatchingEventStorageEngine extends AbstractEventStorageEngine { public int batchSize() { return batchSize; } protected  BatchingEventStorageEngine(Builder builder); int batchSize();  }