### Question:
CSVRepository implements Repository { @Override public CheckpointCloseableIterable<ApiOperation> getAllDocs(byte[] checkpoint) throws RepositoryException { return new CheckpointCloseableIterableImpl.Builder<>(new RepositoryDocIterable()).build(); } CSVRepository(); @Override void init(RepositoryContext repositoryContext); @Override CheckpointCloseableIterable<ApiOperation> getIds(byte[] checkpoint); @Override CheckpointCloseableIterable<ApiOperation> getChanges(byte[] checkpoint); @Override ApiOperation getDoc(Item item); @Override boolean exists(Item item); @Override void close(); @Override CheckpointCloseableIterable<ApiOperation> getAllDocs(byte[] checkpoint);  }### Answer:
@Test public void testGetAllDocs() throws IOException, InterruptedException { File tmpfile = temporaryFolder.newFile(testName.getMethodName() + ".csv"); createFile(tmpfile, testCSVSingle); Properties config = new Properties(); config.put(CSVFileManager.FILEPATH, tmpfile.getAbsolutePath()); config.put(UrlBuilder.CONFIG_COLUMNS, "term"); config.put(CSVFileManager.UNIQUE_KEY_COLUMNS, "term"); config.put(CONTENT_TITLE, "term"); config.put(CONTENT_HIGH, "term,definition"); config.put(CONTENT_LOW, "author"); setupConfig.initConfig(config); CSVRepository csvRepository = new CSVRepository(); csvRepository.init(mockRepositoryContext); try (CheckpointCloseableIterable<ApiOperation> allDocs = csvRepository.getAllDocs(null)) { for (ApiOperation operation : allDocs) { RepositoryDoc doc = (RepositoryDoc) operation; assertEquals(ContentFormat.HTML, doc.getContentFormat()); assertEquals(RequestMode.UNSPECIFIED, doc.getRequestMode()); assertEquals(null, doc.getItem().getAcl()); assertEquals("moma search", doc.getItem().getName()); String html = CharStreams.toString( new InputStreamReader(doc.getContent().getInputStream(), UTF_8)); assertThat(html, containsString("<title>moma search</title>")); assertThat(html, containsString("<h1>moma search</h1>")); assertThat(html, containsString("<h1>Google internal search</h1>")); } } }