有没有办法在一个Java8流中读取两个或更多文件?
我喜欢新的Java8 StreamAPI,并希望不仅将其用于一个文件。通常,我使用以下代码:
Stream<String> lines = Files.lines(Paths.get("/somepathtofile"));
但是,如果可能的话,如何在一个流中读取两个文件呢?
回答:
没有任何额外的帮助程序功能或外部库,最简单的方法是:
Stream<String> lines1 = Files.lines(Paths.get("/somepathtofile"));Stream<String> lines2 = Files.lines(Paths.get("/somepathtoanotherfile"));
Stream.concat(lines1, lines)
.filter(...)
.forEach(...);
如果Files.lines
尚未声明抛出受检查的异常,则可以
Stream.of("/file1", "/file2") .map(Paths::get)
.flatMap(Files::lines)....
但是,a,我们不能这样做。有几种解决方法。一种是制作自己的版本,将Files.lines
其称为标准版本,然后将其IOException
作为捕获并重新抛出UncheckedIOException
。另一种方法是使用抛出检查异常的方法来制造函数的更通用的方法。它看起来像这样:
@FunctionalInterfacepublic interface ThrowingFunction<T,R> extends Function<T,R> {
@Override
public default R apply(T t) {
try {
return throwingApply(t);
} catch (Exception e) {
throw new RuntimeException(e);
}
}
public static<T,R> Function<T,R> wrap(ThrowingFunction<T,R> f) {
return f;
}
R throwingApply(T t) throws Exception;
}
然后
Stream.of("/somefile", "/someotherfile", "/yetanotherfile") .map(Paths::get)
.flatMap(ThrowingFunction.wrap(Files::lines))
.....
那里有几个库需要为每个功能接口编写类似上面的内容的麻烦。
以上是 有没有办法在一个Java8流中读取两个或更多文件? 的全部内容, 来源链接: utcz.com/qa/413926.html