### Question:
DataSourceConstant extends TaskDataSource { @Override public void close() { closed = true; }  @Override void init(); @Nullable @Override Bundle peek(); @Nullable @Override Bundle next(); @Override void close();  }### Answer:
@Test public void repeatForever() throws IOException { source = initSource("bundles:[{A:a,B:1},{C:[1,2],D:[a,b]}], repeat:-1"); for (int i = 0; i < 10; i++) { verifyOnePass(); } source.close(); verifyNoMoreBundles(); }