in pekko-connectors-sample-rotate-logs-to-ftp/src/main/java/playground/filesystem/FileSystemMock.java [38:52]
public void cleanFiles() {
for (Path rootDir : getFileSystem().getRootDirectories()) {
try {
Files.walkFileTree(rootDir, new SimpleFileVisitor<Path>() {
@Override
public FileVisitResult visitFile(Path file, BasicFileAttributes attrs) throws IOException {
Files.deleteIfExists(file);
return FileVisitResult.CONTINUE;
}
});
} catch (Throwable t) {
t.printStackTrace();
}
}
}