java - 在 Stream API 中使用 AutoClosable 接口(interface)

Question

<分区>

Answer 1

一旦流的所有元素都被消耗，就可以 Hook 到流中以“关闭”资源。因此，可以通过以下修改在阅读完所有行后关闭阅读器:

.flatMap(reader -> reader.lines().onClose(() -> close(reader)))

close(AutoClosable) 处理 IOException。

作为概念证明，以下代码和输出已经过测试:

import java.util.stream.Stream;

class Test {
    public static void main(String[] args) {
        Stream.of(1, 2, 3).flatMap(i ->
                Stream.of(i, i * 2).onClose(() ->
                        System.out.println("Closed!")
                )
        ).forEach(System.out::println);
    }
}

1
2
Closed!
2
4
Closed!
3
6
Closed!