如何在功能上处理分割流

Question

给定以下代码，如何将其简化为单个功能行？

    // DELETE CSV TEMP FILES
    final Map<Boolean, List<File>> deleteResults = Stream.of(tmpDir.listFiles())
            .filter(tempFile -> tempFile.getName().endsWith(".csv"))
            .collect(Collectors.partitioningBy(File::delete));

    // LOG SUCCESSES AND FAILURES
    deleteResults.entrySet().forEach(entry -> {
        if (entry.getKey() && !entry.getValue().isEmpty()) {
            LOGGER.debug("deleted temporary files, {}",
                    entry.getValue().stream().map(File::getAbsolutePath).collect(Collectors.joining(",")));
        } else if (!entry.getValue().isEmpty()) {
            LOGGER.debug("failed to delete temporary files, {}",
                    entry.getValue().stream().map(File::getAbsolutePath).collect(Collectors.joining(",")));
        }
    });

这是我遇到的一个常见模式，我有一个流，我想过滤这个流，根据这个过滤器创建两个流，然后我可以对流a做一件事，对流B做另一件事。这是一个反模式，还是以某种方式得到支持？

Answer 1

若要将这两个类别的所有文件记录在一起，在所有元素都已知之前，无法将它们收集到保存它们的数据结构中。不过，您可以简化代码：

Stream.of(tmpDir.listFiles())
      .filter(tempFile -> tempFile.getName().endsWith(".csv"))
      .collect(Collectors.partitioningBy(File::delete,
          Collectors.mapping(File::getAbsolutePath, Collectors.joining(","))))
.forEach((success, files) -> {
    if (!files.isEmpty()) {
        LOGGER.debug(success? "deleted temporary files, {}":
                              "failed to delete temporary files, {}",
                     files);
    }
});

这不会将文件收集到List中，而是首先收集到预期的String中，以便进行后续日志记录操作。两种情况下的日志记录操作也是相同的，但仅在消息中有所不同。

尽管如此，最有趣的事情是为什么删除文件失败，boolean并没有说明这一点。因为Java

创建助手方法

public static String deleteWithReason(Path p) {
    String problem;
    IOException ioEx;

    try {
        Files.delete(p);
        return "";
    }
    catch(FileSystemException ex) {
        problem = ex.getReason();
        ioEx = ex;
    }
    catch(IOException ex) {
        ioEx = ex;
        problem = null;
    }
    return problem!=null? problem.replaceAll("\\.?\\R", ""): ioEx.getClass().getName();
}

像这样使用它

Files.list(tmpDir.toPath())
      .filter(tempFile -> tempFile.getFileName().toString().endsWith(".csv"))
      .collect(Collectors.groupingBy(YourClass::deleteWithReason,
          Collectors.mapping(p -> p.toAbsolutePath().toString(), Collectors.joining(","))))
.forEach((failure, files) -> 
    LOGGER.debug(failure.isEmpty()? "deleted temporary files, {}":
                           "failed to delete temporary files, "+failure+ ", {}",
                 files)
);

如果您想这样称呼它，缺点是如果失败的文件有不同的失败原因，则不会为所有失败的文件生成一个条目。但如果你想把它们记录下来，说明为什么不能删除，这显然是不可避免的。

请注意，如果要从失败中排除“被其他人同时删除”，只需使用文件即可。deleteIfExists（p）而不是文件。删除（p）并且已经被删除将被视为成功。

Answer 2

如果您特别不希望显式变量引用中间映射，那么您可以只链接操作：

.collect(Collectors.partitioningBy(File::delete))
.forEach((del, files) -> {
    if (del) {
        LOGGER.debug(... files.stream()...);
    } else {
        LOGGER.debug(... files.stream()...);
    });