MemoryAsyncLogDataStore implements AsyncLogDataStore { @Override public void setLimit(int limit) { service.submit(new OperationSetLimit(logDataStore, limit)); } MemoryAsyncLogDataStore(ListeningExecutorService service, LogDataStore logDataStore); @Override int getCount(); @Override ListenableFuture remove(final int... ids); @Override ListenableFuture<FilterResult> filter(LogDataFilter filter); @Override ListenableFuture<SearchResult> search(SearchCriteria searchCriteria); @Override LogData getLogData(int row); @Override Integer getLogDataIdInRow(int row); @Override int getLimit(); @Override void setLimit(int limit); @Override void add(final LogData... logDatas); @Override LogData[] getLogData(); @Override int clear(); @Override void addNoteToRow(int row, Note note); @Override Note getNote(int row); @Override Note removeNote(int row); @Override void clearNotes(); @Override TreeMap<Integer, Note> getAllNotes(); @Override Iterator<LogData> iterator(); @Override boolean isMarked(int row); @Override MarkerColors getMarkerColors(int row); @Override void markRows(MarkerColors markerColors, int... rows); @Override void unmarkRows(int... rows);  }
@Test public void testSetLimit() throws Exception { store.setLimit(100); AssertJUnit.assertEquals(100, store.getCount()); }