如何解决有没有办法在一个Java8流中读取两个或更多文件?
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
。另一种方法是使用抛出检查异常的方法来制造函数的更通用的方法。它看起来像这样:
@FunctionalInterface
public 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 StreamAPI,并希望不仅将其用于一个文件。通常,我使用以下代码:
Stream<String> lines = Files.lines(Paths.get("/somepathtofile"));
但是,如果可能的话,如何在一个流中读取两个文件呢?
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。