Multi collectItems 如何提前终止并返回收集的项目

编程问答 2022-05-21

问题描述

在我的 quarkus 服务中，我正在构建 a custom accumulator 以使用 Multi。流可能是无限的，我想知道如何在积累了足够的数据后提前终止并收集结果？

以下是我的原型：

Multi<Data> sortedStream = getStream();
return this.sortedStream.collectItems().in(
    LinkedList::new,new BiConsumer<LinkedList<Coverage>,Data>() {
        @Override
        public void accept(LinkedList<Coverage> coverages,Data incoming) {
        if (coverages.isEmpty()) {
            coverages.add(new Coverage(incoming));
            return;
        }

        if (enough(coverages)) {
            // Question: How to early terminate and collect coverage downstream?
        }

        Coverage last = coverages.getLast();
        if (worthAdd(last,incoming)) {
            coverages.add(new Coverage(incoming));
        } else {
            return;
        }

        }
    }
)

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）

javajavamutinyquarkusstreaming