@Test public void testMax() throws ResourceInitializationException, CollectionException, IOException { FakeStreamCollectionReader r = new FakeStreamCollectionReader(); r.setMaxDocuments(2); r.doInitialize(null); assertTrue(r.doHasNext()); r.doGetNext(null); assertTrue(r.doHasNext()); r.doGetNext(null); assertFalse(r.doHasNext()); }
protected void setMaxDocuments(Integer maxDocuments) { this.maxDocuments = maxDocuments; }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setMaxDocuments(Integer maxDocuments) { this.maxDocuments = maxDocuments; } }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setMaxDocuments(Integer maxDocuments) { this.maxDocuments = maxDocuments; }  }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setMaxDocuments(Integer maxDocuments) { this.maxDocuments = maxDocuments; }   }
AbstractStreamCollectionReader extends AbstractIteratatorCollectionReader<T> { protected void setMaxDocuments(Integer maxDocuments) { this.maxDocuments = maxDocuments; }   static final String KEY_MAX_DOCUMENTS; static final String KEY_SKIP_DOCUMENTS; }