in pekko-connectors-sample-ftp-to-file/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();
}
}
}