Java 8 flatMapped 流在 try-with-resources 块中关闭 [重复]

Question

我有两种方法可以返回列表中字符串的长度，如下所示；

    private Stream<Integer> method1(List<String> list) {
        try (final Stream<String> myStream = list.stream()) {
            return myStream.map(String::length);
        }
    }

和

    private Stream<Integer> method2(List<String> list) {
        try (final Stream<String> myStream = list.stream()) {
            return myStream.map(String::length).flatMap(Stream::of);
        }
    }

当我尝试使用任一方法的结果流时；

    List<Integer> collect = method1(list).collect(Collectors.toList());

或

    List<Integer> collect = method2(list).collect(Collectors.toList());

我明白了

    Exception in thread "main" java.lang.IllegalStateException: source already consumed or closed

现在我知道在 try-with-resources 块中使用流并不常见。但在我的真实代码中，我在 try-with-resources 中使用Stream<Path> paths = Files.walk(Path.of(myPath))。在Files.walk(..) 方法的文档中它说

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

上面的代码只是说明问题的一个例子。

我的问题是，尽管我使用 map 和 flatMap 返回一个新流，但为什么我的流已关闭。我期望这两种方法返回新的Stream 实例，因此只有myStream 被关闭而不是map 操作返回的实例，我错了吗？我对 monad 的理解很模糊，但 map 和 flatMap 方法的行为是否意味着 Stream 不是真正的 monad？

Answer 1

stream 将在 try 块完成后关闭。

因为Stream<T> 扩展了BaseStream<T, Stream<T>> 和BaseStream 扩展了AutoCloseable

为什么我在block中创建的Stream实例也关闭了

因为在块中创建的新Stream 实例是链式嵌套的 myStream 的流，并在 myStream（外部流）关闭后立即关闭。您可以使用onClose 进行验证，如下所示，

privat Stream<Integer> method1(List<String> list) {
    try (final Stream<String> myStream = list.stream()) {
        Stream<Integer> integerStream = myStream.onClose(r)
                .map(String::length).onClose(r1);
        return integerStream;
    }
}
Runnable r = ()->{
    System.out.println("closed main stream...");
};
Runnable r1 = ()->{
    System.out.println("closed map stream...");
};