Java 8 Streams：流式传输文件并在读取后删除

Question

我想流式传输文件中包含的行，但在处理完每个文件后将其删除。

目前的流程是这样的：

解释：

1. 我创建了一个文件流
2. 我为它们中的每一个创建一个 BufferedReader
3. 我将平面映射到 BufferedReader 的行流
4. 我打印每一行。

代码：

(1)    Stream.generate(localFileProvider::getNextFile)
(2)       .map(file -> return new BufferedReader(new InputStreamReader(new FileInputStream(file))))
(3)       .flatMap(BufferedReader::lines)
(4)       .map(System.out::println);

是否可以在完全读取每个文件后将其删除并继续处理流中的其他文件？

谢谢！

Answer 1

当您使用flatMap 时，函数返回的流将在处理完毕后自动关闭。您只需要在打开InputStream 时添加一个选项，指定其基础文件应在关闭时被删除。

假设localFileProvider.getNextFile() 返回java.io.File，代码如下所示

Stream.generate(localFileProvider::getNextFile)
    .takeWhile(Objects::nonNull) // stop on null, otherwise, it’s an infinite stream

// the actual operation regarding your question:
    .flatMap(file -> {
        try { return new BufferedReader(new InputStreamReader(
            Files.newInputStream(file.toPath(), StandardOpenOption.DELETE_ON_CLOSE)))
            .lines();
        } catch(IOException ex) { throw new UncheckedIOException(ex); }
    })

// the example terminal operation
    .forEach(System.out::println);

您需要使用Files.newInputStream(Path, OpenOption...) 而不是new FileInputStream(…) 来指定特殊的打开选项。所以上面的代码通过toPath() 将File 转换为Path；如果getNextFile() 返回String，则需要Paths.get(file)。