@Test void iterator_noValues() { VcfRepository vcfRepository = new VcfRepository(testNoData, "testNoData", vcfAttrs, entityTypeFactory, attrMetaFactory); vcfRepository.forEachBatched(batchConsumer, 1000); verifyZeroInteractions(batchConsumer); }
@Override public void forEachBatched(Consumer<List<Entity>> consumer, int batchSize) { withReader( reader -> stream(partition(transform(reader.iterator(), vcfToEntity::toEntity), batchSize)) .forEach(consumer)); }
VcfRepository extends AbstractRepository { @Override public void forEachBatched(Consumer<List<Entity>> consumer, int batchSize) { withReader( reader -> stream(partition(transform(reader.iterator(), vcfToEntity::toEntity), batchSize)) .forEach(consumer)); } }
VcfRepository extends AbstractRepository { @Override public void forEachBatched(Consumer<List<Entity>> consumer, int batchSize) { withReader( reader -> stream(partition(transform(reader.iterator(), vcfToEntity::toEntity), batchSize)) .forEach(consumer)); } VcfRepository(
      File file,
      String entityTypeId,
      VcfAttributes vcfAttributes,
      EntityTypeFactory entityTypeFactory,
      AttributeFactory attrMetaFactory); }
VcfRepository extends AbstractRepository { @Override public void forEachBatched(Consumer<List<Entity>> consumer, int batchSize) { withReader( reader -> stream(partition(transform(reader.iterator(), vcfToEntity::toEntity), batchSize)) .forEach(consumer)); } VcfRepository(
      File file,
      String entityTypeId,
      VcfAttributes vcfAttributes,
      EntityTypeFactory entityTypeFactory,
      AttributeFactory attrMetaFactory); @Override Iterator<Entity> iterator(); EntityType getEntityType(); @Override Set<RepositoryCapability> getCapabilities(); @Override long count(); @Override void forEachBatched(Consumer<List<Entity>> consumer, int batchSize); }
VcfRepository extends AbstractRepository { @Override public void forEachBatched(Consumer<List<Entity>> consumer, int batchSize) { withReader( reader -> stream(partition(transform(reader.iterator(), vcfToEntity::toEntity), batchSize)) .forEach(consumer)); } VcfRepository(
      File file,
      String entityTypeId,
      VcfAttributes vcfAttributes,
      EntityTypeFactory entityTypeFactory,
      AttributeFactory attrMetaFactory); @Override Iterator<Entity> iterator(); EntityType getEntityType(); @Override Set<RepositoryCapability> getCapabilities(); @Override long count(); @Override void forEachBatched(Consumer<List<Entity>> consumer, int batchSize); static final String DEFAULT_ATTRIBUTE_DESCRIPTION; static final String NAME; static final String ORIGINAL_NAME; static final int BATCH_SIZE; }