@Test void addEntitiesStreamBidi() { initEntityMetaBidi(); Stream<Entity> entities = Stream.empty(); when(delegateRepository.add(entities)).thenReturn(123); assertEquals(valueOf(123), indexActionRepositoryDecorator.add(entities)); verify(delegateRepository, times(1)).add(entities); verify(indexActionRegisterService).register(entityType, null); verify(indexActionRegisterService).register(mappedByEntity, null); verify(indexActionRegisterService).register(inversedByEntity, null); verifyNoMoreInteractions(indexActionRegisterService); }
@Override public void add(Entity entity) { delegate().add(entity); indexActionRegisterService.register(getEntityType(), entity.getIdValue()); registerRefEntityIndexActions(entity); }
IndexActionRepositoryDecorator extends AbstractRepositoryDecorator<Entity> { @Override public void add(Entity entity) { delegate().add(entity); indexActionRegisterService.register(getEntityType(), entity.getIdValue()); registerRefEntityIndexActions(entity); } }
IndexActionRepositoryDecorator extends AbstractRepositoryDecorator<Entity> { @Override public void add(Entity entity) { delegate().add(entity); indexActionRegisterService.register(getEntityType(), entity.getIdValue()); registerRefEntityIndexActions(entity); } IndexActionRepositoryDecorator(
      Repository<Entity> delegateRepository,
      IndexActionRegisterService indexActionRegisterService); }
IndexActionRepositoryDecorator extends AbstractRepositoryDecorator<Entity> { @Override public void add(Entity entity) { delegate().add(entity); indexActionRegisterService.register(getEntityType(), entity.getIdValue()); registerRefEntityIndexActions(entity); } IndexActionRepositoryDecorator(
      Repository<Entity> delegateRepository,
      IndexActionRegisterService indexActionRegisterService); @Override Set<RepositoryCapability> getCapabilities(); @Override void update(Entity entity); @Override void delete(Entity entity); @Override void deleteById(Object id); @Override void deleteAll(); @Override void add(Entity entity); @Override Integer add(Stream<Entity> entities); @Override void update(Stream<Entity> entities); @Override void delete(Stream<Entity> entities); @Override void deleteAll(Stream<Object> ids); }
IndexActionRepositoryDecorator extends AbstractRepositoryDecorator<Entity> { @Override public void add(Entity entity) { delegate().add(entity); indexActionRegisterService.register(getEntityType(), entity.getIdValue()); registerRefEntityIndexActions(entity); } IndexActionRepositoryDecorator(
      Repository<Entity> delegateRepository,
      IndexActionRegisterService indexActionRegisterService); @Override Set<RepositoryCapability> getCapabilities(); @Override void update(Entity entity); @Override void delete(Entity entity); @Override void deleteById(Object id); @Override void deleteAll(); @Override void add(Entity entity); @Override Integer add(Stream<Entity> entities); @Override void update(Stream<Entity> entities); @Override void delete(Stream<Entity> entities); @Override void deleteAll(Stream<Object> ids);  }