@Test void testDeleteStream() { FileMeta fileMeta0 = getMockFileMeta("id0"); FileMeta fileMeta1 = getMockFileMeta("id1"); fileMetaRepositoryDecorator.delete(Stream.of(fileMeta0, fileMeta1)); @SuppressWarnings("unchecked") ArgumentCaptor<Stream<FileMeta>> captor = ArgumentCaptor.forClass(Stream.class); verify(delegateRepository).delete(captor.capture()); assertEquals(asList(fileMeta0, fileMeta1), captor.getValue().collect(toList())); verify(fileStore).delete("id0"); verify(fileStore).delete("id1"); }
@Override public void delete(FileMeta fileMeta) { deleteFile(fileMeta); super.delete(fileMeta); }
FileMetaRepositoryDecorator extends AbstractRepositoryDecorator<FileMeta> { @Override public void delete(FileMeta fileMeta) { deleteFile(fileMeta); super.delete(fileMeta); } }
FileMetaRepositoryDecorator extends AbstractRepositoryDecorator<FileMeta> { @Override public void delete(FileMeta fileMeta) { deleteFile(fileMeta); super.delete(fileMeta); } FileMetaRepositoryDecorator(
      Repository<FileMeta> delegateRepository, FileStore fileStore, BlobStore blobStore); }
FileMetaRepositoryDecorator extends AbstractRepositoryDecorator<FileMeta> { @Override public void delete(FileMeta fileMeta) { deleteFile(fileMeta); super.delete(fileMeta); } FileMetaRepositoryDecorator(
      Repository<FileMeta> delegateRepository, FileStore fileStore, BlobStore blobStore); @Override void delete(FileMeta fileMeta); @Override void deleteById(Object id); @Override void deleteAll(); @Override void delete(Stream<FileMeta> fileMetaStream); @Override void deleteAll(Stream<Object> ids); }
FileMetaRepositoryDecorator extends AbstractRepositoryDecorator<FileMeta> { @Override public void delete(FileMeta fileMeta) { deleteFile(fileMeta); super.delete(fileMeta); } FileMetaRepositoryDecorator(
      Repository<FileMeta> delegateRepository, FileStore fileStore, BlobStore blobStore); @Override void delete(FileMeta fileMeta); @Override void deleteById(Object id); @Override void deleteAll(); @Override void delete(Stream<FileMeta> fileMetaStream); @Override void deleteAll(Stream<Object> ids);  }