声纳-使用Try-with-Resources或在&quot；Finally&quot；子句java8流中关闭此流(&q；Stream&quot；)

Sonar Qube给我以下错误

使用TRY-WITH-RESOURCES或在"Finally"子句中关闭此"Stream"

List<Path> paths = find(Paths.get(nasProps.getUpstreamOutputDirectory() + File.separator + inputSource.concat("_").concat(contentGroup).concat("_").concat(parentId)),
                MAX_VALUE, (filePath, fileAttr) -> fileAttr.isRegularFile() && filePath.getFileName().toString().matches(".*\." + extTxt))
                .collect(toList());
paths.stream().forEach(path -> textFileQueue.add(path));

我对java8了解不多。您能帮我关闭这条流吗？

---

解决方案

假设find这里是Files.find，那么您应该使用的是

final Path startPath = Paths.get(nasProps.getUpstreamOutputDirectory() +
        File.separator +
        inputSource.concat("_").concat(contentGroup).concat("_").concat(parentId));
BiPredicate<Path, BasicFileAttributes> matcher = (filePath, fileAttr) ->
        fileAttr.isRegularFile() && filePath.getFileName().toString().matches(".*\." + extTxt);

try (Stream<Path> pathStream = Files.find(startPath, Integer.MAX_VALUE, matcher)) {
    pathStream.forEach(path -> textFileQueue.add(path));
} catch (IOException e) {
    e.printStackTrace(); // handle or add to method calling this block
}

链接文档的API备注中也提到了sonarqube在这里出现警告的原因：

此方法必须在try-with-resources语句中使用，或者 类似的控制结构，以确保流的打开目录 在流的操作完成后立即关闭。