首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >问答首页 >在Java 8中,如何从有限流构建无限重复流?

在Java 8中,如何从有限流构建无限重复流?
EN

Stack Overflow用户
提问于 2018-01-06 02:07:52
回答 3查看 806关注 0票数 3

如何将有限的事物流Stream<Thing>转换为无限重复的事物流?

EN

回答 3

Stack Overflow用户

回答已采纳

发布于 2018-01-06 02:50:14

蜘蛛鲍里斯是对的:一个流只能被遍历一次,所以你需要一个Supplier<Stream<Thing>>或者你需要一个集合。

代码语言:javascript
运行
复制
<T> Stream<T> repeat(Supplier<Stream<T>> stream) {
    return Stream.generate(stream).flatMap(s -> s);
}

<T> Stream<T> repeat(Collection<T> collection) {
    return Stream.generate(() -> collection.stream()).flatMap(s -> s);
}

示例调用:

代码语言:javascript
运行
复制
Supplier<Stream<Thing>> stream = () ->
    Stream.of(new Thing(1), new Thing(2), new Thing(3));

Stream<Thing> infinite = repeat(stream);
infinite.limit(50).forEachOrdered(System.out::println);

System.out.println();

Collection<Thing> things =
    Arrays.asList(new Thing(1), new Thing(2), new Thing(3));

Stream<Thing> infinite2 = repeat(things);
infinite2.limit(50).forEachOrdered(System.out::println);
票数 5
EN

Stack Overflow用户

发布于 2018-01-06 02:56:48

如果你手头有一个Guava和一个Collection,你可以做以下事情。

代码语言:javascript
运行
复制
final Collection<Thing> thingCollection = ???;
final Iterable<Thing> cycle = Iterables.cycle(thingCollection);
final Stream<Thing> things = Streams.stream(cycle);

但是如果你有一个Stream而不是一个Collection,这不会有什么帮助。

票数 1
EN

Stack Overflow用户

发布于 2018-01-06 03:03:11

如果你有一个有限的流,并且知道它可以放在内存中,你可以使用一个中间集合。

代码语言:javascript
运行
复制
final Stream<Thing> finiteStream = ???;
final List<Thing> finiteCollection = finiteStream.collect(Collectors.toList());
final Stream<Thing> infiniteThings = Stream.generate(finiteCollection::stream).flatMap(Functions.identity());
票数 1
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/48119039

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档